- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 205 for waits (0.02 seconds)
-
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. */Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 17K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
} return this; } /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /**Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 33.2K bytes - Click Count (1) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
} return this; } /** * Waits for the all the services to reach a terminal state. After this method returns all * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain * Service.State#FAILED failed}. */ public void awaitStopped() { state.awaitStopped(); } /**Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 17:49:12 GMT 2025 - 32.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
threadUnexpectedException(t); } } // /** // * Spin-waits up to LONG_DELAY_MS until flag becomes true. // */ // public void await(AtomicBoolean flag) { // await(flag, LONG_DELAY_MS); // } // /** // * Spin-waits up to the specified timeout until flag becomes true. // */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 20:07:52 GMT 2025 - 37.8K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/interval/impl/HostIntervalController.java
* The delay is calculated based on the configured delayMillisBeforeProcessing parameter. * If the time since the last request to the host is less than the configured delay, * the thread waits until the delay has elapsed. * This class is thread-safe. * The cache automatically evicts entries after 1 hour of inactivity to prevent memory leaks. */ public class HostIntervalController extends DefaultIntervalController {Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Mon Nov 24 03:59:47 GMT 2025 - 5.2K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
/** * Converts the given ThreadPoolExecutor into an ExecutorService that exits when the application * is complete. It does so by using daemon threads and adding a shutdown hook to wait for their * completion. * * <p>This method waits 120 seconds before continuing with JVM termination, even if the executor * has not finished its work. *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Wed Oct 08 18:55:33 GMT 2025 - 45.2K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/DataIndexHelper.java
} } } /** * Waits for the crawling thread to terminate within a specified time limit. * This method blocks until the thread completes or the timeout expires. * * @param mills maximum time to wait in milliseconds */ public void awaitTermination(final long mills) { try {Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 19K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/helper/IntervalControlHelper.java
// Default constructor } /** Wait time in milliseconds when crawler is not running */ protected long crawlerWaitMillis = 10000; /** List of interval rules for controlling crawler timing */ protected List<IntervalRule> ruleList = new ArrayList<>(); /** * Checks the crawler status and waits if the crawler is not running.Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Sun Nov 23 12:34:02 GMT 2025 - 10K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 11.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 11 21:00:51 GMT 2025 - 11.4K bytes - Click Count (0)