- Sort Score
- Num 10 results
- Language All
Results 1 - 5 of 5 for startThread (0.16 seconds)
-
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
CountDownLatch startedLatch = new CountDownLatch(1); startThread( () -> { startedLatch.countDown(); enterSatisfyGuardAndLeaveInCurrentThread(); }); awaitUninterruptibly(startedLatch); } private void enterAndRemainOccupyingInAnotherThread() { CountDownLatch enteredLatch = new CountDownLatch(1); startThread( () -> { monitor.enter();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.GeneratedMonitorTest.startThread; import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SupplementalMonitorTest.java
* limitations under the License. */ package com.google.common.util.concurrent; import static com.google.common.truth.Truth.assertThat; import static com.google.common.util.concurrent.GeneratedMonitorTest.startThread; import static com.google.common.util.concurrent.Uninterruptibles.joinUninterruptibly; import static org.junit.Assert.assertThrows; import com.google.common.annotations.GwtIncompatible;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
CountDownLatch startedLatch = new CountDownLatch(1); startThread( () -> { startedLatch.countDown(); enterSatisfyGuardAndLeaveInCurrentThread(); }); awaitUninterruptibly(startedLatch); } private void enterAndRemainOccupyingInAnotherThread() { CountDownLatch enteredLatch = new CountDownLatch(1); startThread( () -> { monitor.enter();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 26.7K bytes - Click Count (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
* and extracts child URLs until the crawling process is done or no more URLs are available. */ @Override public void run() { log(logHelper, LogType.START_THREAD, crawlerContext); int threadCheckCount = 0; // set urlQueue to thread CrawlingParameterUtil.setCrawlerContext(crawlerContext); CrawlingParameterUtil.setUrlQueueService(urlQueueService);Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Wed Dec 31 09:07:38 GMT 2025 - 20.3K bytes - Click Count (0)