- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 74 for countdown (0.12 sec)
-
guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java
} @Override void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) { assertThat(closingFuture.finishToFuture().cancel(false)).isTrue(); waitUntilClosed(closingFuture); futureCancelled.countDown(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 3.7K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
super(event); } @Override public void process(Consumer<TransferEvent> consumer) { super.process(consumer); latch.countDown(); } @Override public void waitForProcessed() throws InterruptedException { latch.await(); } }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
synchronized(this) { this.publicSuffixListBytes = publicSuffixListBytes!! this.publicSuffixExceptionListBytes = publicSuffixExceptionListBytes!! } } finally { readCompleteLatch.countDown() } } /** Visible for testing. */ fun setListBytes( publicSuffixListBytes: ByteArray, publicSuffixExceptionListBytes: ByteArray, ) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/QueuesTest.java
} @Override public @Nullable Void call() throws InterruptedException { try { beganProducing.countDown(); for (int i = 0; i < elements; i++) { q.put(new Object()); } return null; } finally { doneProducing.countDown(); } } } private static class Interrupter implements Runnable { final Thread threadToInterrupt;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 12.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Thu Apr 11 22:09:35 UTC 2024 - 75.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} }); future.get(10, SECONDS); assertThrows(RejectedExecutionException.class, () -> executor.execute(Runnables.doNothing())); latch.countDown(); ExecutionException expected = assertThrows(ExecutionException.class, () -> first.get(10, SECONDS)); assertThat(expected).hasCauseThat().isInstanceOf(RejectedExecutionException.class); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
Thread thread = new Thread() { @Override public void run() { try { cacheRef.get().getUnchecked(3); } finally { doneSignal.countDown(); } } }; thread.setUncaughtExceptionHandler( new UncaughtExceptionHandler() { @Override public void uncaughtException(Thread t, Throwable e) {}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 12.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalLoadingCacheTest.java
Thread thread = new Thread() { @Override public void run() { try { cacheRef.get().getUnchecked(3); } finally { doneSignal.countDown(); } } }; thread.setUncaughtExceptionHandler( new UncaughtExceptionHandler() { @Override public void uncaughtException(Thread t, Throwable e) {}
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 12.4K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java
executor.execute(new ResolveTask( classLoader, latch, artifact, session, node.getRemoteRepositories(), result)); } else { latch.countDown(); } } try { latch.await(); } catch (InterruptedException e) { result.addErrorArtifactException(
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 24.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt
clientListener.assertOpen() clientListener.assertFailure( SocketTimeoutException::class.java, "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)", ) latch.countDown() val elapsedUntilFailure = System.nanoTime() - openAtNanos assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble()) .isCloseTo(1000.0, 250.0) }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Mar 31 17:16:15 UTC 2024 - 35.2K bytes - Viewed (0)