- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for countdown (0.12 sec)
-
okhttp/src/test/java/okhttp3/AutobahnTester.kt
reason: String, ) { webSocket.close(1000, null) latch.countDown() } override fun onFailure( webSocket: WebSocket, t: Throwable, response: Response?, ) { t.printStackTrace(System.out) latch.countDown() } }, )
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
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(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
protected final ListenableFutureTask<Integer> task = ListenableFutureTask.create( new Callable<Integer>() { @Override public Integer call() throws Exception { runLatch.countDown(); taskLatch.await(); if (throwException) { throw new IllegalStateException("Fail"); } return 25; } });
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
TrustedListenableFutureTask.create( new Callable<Integer>() { @Override public Integer call() throws Exception { enterLatch.countDown(); try { new CountDownLatch(1).await(); // wait forever throw new AssertionError(); } catch (InterruptedException e) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 7.3K bytes - Viewed (0) -
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(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 18:30:30 UTC 2023 - 6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
} catch (final Exception e) { logger.warn("Could not close a process input stream.", e); } finally { latch.countDown(); } }, "ProcessCloser-input-" + sessionId).start(); new Thread(() -> { try { CloseableUtil.closeQuietly(process.getErrorStream());
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 6.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
@Override @Nullable Void runInterruptibly() throws Exception { BrokenChannel bc = new BrokenChannel(); bc.doBegin(); isInterruptibleRegistered.countDown(); new CountDownLatch(1).await(); // the interrupt will wake us up return null; } @Override boolean isDone() { return false; }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
} latch.countDown() } override fun onFailure( hostname: String, e: IOException, ) { synchronized(allExceptions) { allExceptions.add(e) } latch.countDown() } }, ) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
} }; Thread thread1 = new Thread(execute); Thread thread2 = new Thread(execute); thread1.start(); thread2.start(); assertEquals(0, runCalled.get()); okayToRun.countDown(); thread1.join(); thread2.join(); assertEquals(1, runCalled.get()); } public void testAddAfterRun() throws Exception { // Run the previous test testRunOnPopulatedList();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
compat/maven-embedder/src/test/java/org/apache/maven/cli/transfer/ConsoleMavenTransferListenerTest.java
.setTransferredBytes(bytes) .build(); startLatch.countDown(); try { listener.transferProgressed(event); } catch (TransferCancelledException e) { } endLatch.countDown(); }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5K bytes - Viewed (0)