- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 62 for countdown (0.07 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) -
okhttp/src/test/java/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 {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 18.7K 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) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
service.expectedShutdownState = Service.State.RUNNING; service.startAsync().awaitRunning(); assertTrue(service.startUpCalled); assertEquals(Service.State.RUNNING, service.state()); exitRun.countDown(); // the service will exit voluntarily executionThread.join(); assertTrue(service.shutDownCalled); assertEquals(Service.State.TERMINATED, service.state());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 12.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) -
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) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
* * <p>Here's an example that tests a {@code finalize} method: * * <pre>{@code * final CountDownLatch latch = new CountDownLatch(1); * Object x = new MyClass() { * ... * protected void finalize() { latch.countDown(); ... } * }; * x = null; // Hint to the JIT that x is stack-unreachable * GcFinalization.await(latch); * }</pre> * * <p>Here's an example that uses a user-defined finalization predicate: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:26:48 UTC 2024 - 11.6K bytes - Viewed (0)