- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 178 for wait (0.03 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java
// the run latch. exec.execute(task); runLatch.await(); assertEquals(1, listenerLatch.getCount()); assertFalse(task.isDone()); assertFalse(task.isCancelled()); // Finish the task by unblocking the task latch. Then wait for the // listener to be called by blocking on the listener latch. taskLatch.countDown();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 4.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #1 barrier.await(1, SECONDS); // WAIT #2 barrier.await(1, SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3 barrier.await(1, SECONDS); return null;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 00:25:21 UTC 2025 - 26.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
// WAIT #1 barrier.await(1, SECONDS); // WAIT #2 barrier.await(1, SECONDS); assertTrue(executor.isShutdown()); assertFalse(executor.isTerminated()); // WAIT #3 barrier.await(1, SECONDS); return null;Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 12 00:25:21 UTC 2025 - 26.5K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/interval/impl/HostIntervalControllerTest.java
executor.shutdownNow(); } } long elapsed = (System.nanoTime() - time) / 1000000; long wait = waittime * (numTasks - 1); assertTrue(elapsed + " >= " + wait, elapsed + 1L >= wait); } /** * Test that different hosts can be accessed concurrently without delay */ public void test_multipleHosts_concurrent() {
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 11.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/IntervalControlHelper.java
} return values; } /** * Sets the wait time in milliseconds when the crawler is not running. * * @param crawlerWaitMillis the wait time in milliseconds */ public void setCrawlerWaitMillis(final long crawlerWaitMillis) { this.crawlerWaitMillis = crawlerWaitMillis; }Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sun Nov 23 12:34:02 UTC 2025 - 10K bytes - Viewed (0) -
docs/releasing.md
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 19 15:45:22 UTC 2025 - 1.1K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/Crawler.java
} /** * Waits for the crawling process to terminate indefinitely. */ public void awaitTermination() { awaitTermination(0); } /** * Waits for the crawling process to terminate for a specified duration. * @param millis The maximum time to wait in milliseconds. A value of 0 means wait indefinitely. */Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 17K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java
crawler.getCrawlerContext().setMaxAccessCount(maxCount); crawler.getCrawlerContext().setNumOfThread(numOfThread); final String sessionId = crawler.execute(); // Wait for crawler to start running with polling long startTime = System.currentTimeMillis(); while (crawler.crawlerContext.getStatus() != CrawlerStatus.RUNNING && System.currentTimeMillis() - startTime < 5000) {
Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Tue Nov 11 13:40:14 UTC 2025 - 25.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/net/protocol/gcs/HandlerTest.java
// Create multiple threads that all try to connect simultaneously for (int i = 0; i < threadCount; i++) { new Thread(() -> { try { startLatch.await(); // Wait for signal to start conn.connect(); successCount.incrementAndGet(); } catch (Exception e) { synchronized (exceptions) {Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 14.1K bytes - Viewed (0)