Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for startThread (0.16 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
Back to Top