Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 178 for wait (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. docs/releasing.md

        git push && git push --tags
    
       sed -i "" \
          "s/version = \".*\"/version = \"$NEXT_VERSION\"/g" \
          build.gradle.kts
        git commit -am "Prepare next development version."
        git push
        ```
    
    4. Wait for [GitHub Actions][github_actions] to build and promote the release.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 19 15:45:22 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top