IncrementingLoader loader = incrementingLoader();
    LoadingCache<Integer, Integer> cache =
        CacheBuilder.newBuilder()
            .refreshAfterWrite(3, MILLISECONDS)
            .expireAfterWrite(6, MILLISECONDS)
            .lenientParsing()
            .ticker(ticker)
            .build(loader);
    int expectedLoads = 0;
    int expectedReloads = 0;
    for (int i = 0; i < 3; i++) {

    assertTrue(future.isCancelled());
    assertTrue(future.isDone());

    assertTrue(successLatch.await(200, MILLISECONDS));
    assertTrue(listenerLatch.await(200, MILLISECONDS));

    latch.countDown();

    exec.shutdown();
    exec.awaitTermination(100, MILLISECONDS);
  }

  /**
   * Tests that all listeners complete, even if they were added before or after the future was

    /** Time taken for the operation in milliseconds. */
    protected final long took;

    /**
     * Constructor for SuggestIndexResponse.
     * @param numberOfSuggestDocs The number of suggest documents.
     * @param numberOfInputDocs The number of input documents.
     * @param errors A list of Throwables representing errors.
     * @param took The time taken for the operation in milliseconds.
     */

    }

    /**
     * Sets the time taken for the search in milliseconds.
     * @param tookInMillis The time taken in milliseconds.
     */
    public void setTookInMillis(final long tookInMillis) {
        this.tookInMillis = tookInMillis;
    }

    /**
     * Returns the time taken for the search in milliseconds.
     * @return The time taken in milliseconds.
     */
    public long getTookInMillis() {

 *
 * ```java
 * public final OkHttpClient client = new OkHttpClient.Builder()
 *     .readTimeout(1000, TimeUnit.MILLISECONDS)
 *     .writeTimeout(1000, TimeUnit.MILLISECONDS)
 *     .build();
 * ```
 *
 * This example shows a call with a short 500 millisecond read timeout and a 1000 millisecond
 * write timeout. Original configuration is kept, but can be overriden.
 *
 * ```java

    /** List of command strings to execute for thumbnail generation. */
    protected List<String> commandList;

    /** Timeout for command execution in milliseconds. */
    protected long commandTimeout = 30 * 1000L;// 30sec

    /** Timeout for destroying processes in milliseconds. */
    protected long commandDestroyTimeout = 5 * 1000L;// 5sec

    /** Base directory for command execution. */
    protected File baseDir;

     */
    int getAttributes();

    /**
     * Gets the creation time.
     *
     * @return the creation time in milliseconds since epoch
     */
    long createTime();

    /**
     * Gets the last modified time.
     *
     * @return the last modified time in milliseconds since epoch
     */
    long lastModified();

    /**
     * Gets the file size.
     *
     * @return the file size in bytes

        .headersDelay(1500, TimeUnit.MILLISECONDS)
        .build(),
    )
    val request =
      Request
        .Builder()
        .url(server.url("/"))
        .post(DelayedRequestBody("hello".toRequestBody(null), 1500, TimeUnit.MILLISECONDS))
        .build()
    client =
      client
        .newBuilder()
        .readTimeout(1000, TimeUnit.MILLISECONDS)
        .build()

      Stopwatch timer = Stopwatch.createStarted();

      int drained = drain(q, new ArrayList<>(), 2, 10, MILLISECONDS, interruptibly);
      assertThat(drained).isAtMost(1);

      assertThat(timer.elapsed(MILLISECONDS)).isAtLeast(10L);

      // If even the first one wasn't there, clean up so that the next test doesn't see an element.
      producerThread.cancel(true);
      producer.doneProducing.await();

     *
     * @param project The project being summarized, must not be {@code null}.
     * @param execTime The exec time of the project in milliseconds.
     * @param wallTime The wall time of the project in milliseconds.
     * @param cause The cause of the build failure, may be {@code null}.
     */
    public BuildFailure(MavenProject project, Duration execTime, Duration wallTime, Throwable cause) {