CountDown - Code Search

guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

              successLatch.countDown();
            })
        .start();

    assertFalse(future.isDone());
    assertFalse(future.isCancelled());

    future.cancel(true);

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

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

    latch.countDown();
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Jul 11 18:52:30 GMT 2025

- 6.1K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

    for (int i = 0; i < SIZE; i++) {
      aa.set(i, (double) COUNTDOWN);
    }
    Counter c1 = new Counter(aa);
    Counter c2 = new Counter(aa);
    Thread t1 = newStartedThread(c1);
    Thread t2 = newStartedThread(c2);
    awaitTermination(t1);
    awaitTermination(t2);
    assertEquals(SIZE * COUNTDOWN, c1.counts + c2.counts);
  }

  /** a deserialized serialized array holds same values */

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 10.8K bytes

- Click Count (0)

github.com/google/guava

android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

              successLatch.countDown();
            })
        .start();

    assertFalse(future.isDone());
    assertFalse(future.isCancelled());

    future.cancel(true);

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

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

    latch.countDown();
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Fri Jul 11 18:52:30 GMT 2025

- 6.1K bytes

- Click Count (0)

github.com/square/okhttp

okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt

          latch2.countDown()
        }
      }
    val request2Listener: EventListener =
      object : EventListener() {
        override fun connectStart(
          call: Call,
          inetSocketAddress: InetSocketAddress,
          proxy: Proxy,
        ) {
          // Let request1 proceed to make a connection.
          latch1.countDown()
          try {

Created: Fri Apr 03 11:42:14 GMT 2026

- Last Modified: Thu Jun 19 11:44:16 GMT 2025

- 19.1K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

    }

    abstract void doAction();
  }

  private static class CountDown extends DelayedActionRunnable {
    private final CountDownLatch latch;

    CountDown(CountDownLatch latch, long tMinus) {
      super(tMinus);
      this.latch = latch;
    }

    @Override
    protected void doAction() {
      latch.countDown();
    }
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 38.1K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/AtomicDoubleArrayTest.java

    for (int i = 0; i < SIZE; i++) {
      aa.set(i, (double) COUNTDOWN);
    }
    Counter c1 = new Counter(aa);
    Counter c2 = new Counter(aa);
    Thread t1 = newStartedThread(c1);
    Thread t2 = newStartedThread(c2);
    awaitTermination(t1);
    awaitTermination(t2);
    assertEquals(SIZE * COUNTDOWN, c1.counts + c2.counts);
  }

  /** a deserialized serialized array holds same values */

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Thu Mar 12 17:47:10 GMT 2026

- 14.8K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

          () -> {
            runLatch.countDown();
            taskLatch.await();
            if (throwException) {
              throw new IllegalStateException("Fail");
            }
            return 25;
          });

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    exec = newCachedThreadPool();

    task.addListener(listenerLatch::countDown, directExecutor());
  }

  @Override

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 4.7K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

          () -> {
            runLatch.countDown();
            taskLatch.await();
            if (throwException) {
              throw new IllegalStateException("Fail");
            }
            return 25;
          });

  @Override
  protected void setUp() throws Exception {
    super.setUp();

    exec = newCachedThreadPool();

    task.addListener(listenerLatch::countDown, directExecutor());
  }

  @Override

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 4.7K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

    this.exec = newCachedThreadPool();
    this.future = checkNotNull(future);
    this.latch = new CountDownLatch(1);
  }

  public void setUp() {
    future.addListener(latch::countDown, exec);

    assertEquals(1, latch.getCount());
    assertFalse(future.isDone());
    assertFalse(future.isCancelled());
  }

  public void tearDown() {
    exec.shutdown();
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 3.3K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

    }

    abstract void doAction();
  }

  private static class CountDown extends DelayedActionRunnable {
    private final CountDownLatch latch;

    CountDown(CountDownLatch latch, long tMinus) {
      super(tMinus);
      this.latch = latch;
    }

    @Override
    protected void doAction() {
      latch.countDown();
    }
  }

Created: Fri Apr 03 12:43:13 GMT 2026

- Last Modified: Mon Mar 16 22:45:21 GMT 2026

- 38.1K bytes

- Click Count (0)

Search Options