- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 94 for CountDown (0.07 sec)
-
src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java
startLatch.await(); response.received(); endLatch.countDown(); } catch (InterruptedException e) { // Ignore } }).start(); } startLatch.countDown(); assertTrue(endLatch.await(1, TimeUnit.SECONDS)); assertTrue(response.isReceived());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.3K bytes - Viewed (0) -
android/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 Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.8K bytes - Viewed (0) -
src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java
fail("Unexpected exception: " + e.getMessage()); } finally { completeLatch.countDown(); } }).start(); } // Start all threads simultaneously startLatch.countDown(); // Wait for completion assertTrue(completeLatch.await(5, TimeUnit.SECONDS)); // Authenticator should be closed
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java
Thread.currentThread().interrupt(); } finally { endLatch.countDown(); } } }); } startLatch.countDown(); endLatch.await(10, TimeUnit.SECONDS); executor.shutdown();
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 25.6K bytes - Viewed (0) -
src/test/java/jcifs/smb/CriticalPerformanceTest.java
} catch (InterruptedException e) { Thread.currentThread().interrupt(); } finally { endLatch.countDown(); } }); } startLatch.countDown(); // Start all threads assertTrue(endLatch.await(30, TimeUnit.SECONDS), "All threads should complete within timeout"); executor.shutdown();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 15.3K bytes - Viewed (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
rejectedCount.incrementAndGet(); } } finally { completeLatch.countDown(); } }); } startLatch.countDown(); assertTrue(completeLatch.await(5, TimeUnit.SECONDS), "All tasks should complete"); executor.shutdown();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0) -
src/test/java/jcifs/smb/PreauthIntegrityTest.java
fail("Thread failed: " + e.getMessage()); } finally { doneLatch.countDown(); } }); } // Start all threads at once startLatch.countDown(); // Wait for completion assertTrue(doneLatch.await(5, TimeUnit.SECONDS), "Threads did not complete in time");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 3.3K 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 Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 12.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
* * <p>Here's an example that tests a {@code finalize} method: * * {@snippet : * 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); * } * * <p>Here's an example that uses a user-defined finalization predicate: * * {@snippet :
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 11.5K bytes - Viewed (0)