Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 688 for Thread (0.03 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
      // may put a thread into an uninterruptible operation intentionally, so there is no other way to
      // clean up these threads.
      @SuppressWarnings("deprecation")
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/exception/UserRoleLoginExceptionTest.java

            Thread thread2 = new Thread(() -> {
                Throwable result = exception.fillInStackTrace();
                assertNull(result);
            });
    
            thread1.start();
            thread2.start();
    
            try {
                thread1.join();
                thread2.join();
            } catch (InterruptedException e) {
                fail("Thread interrupted");
            }
        }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/base/SuppliersTest.java

                int nextValue = counter + 1;
                Thread.yield();
                counter = nextValue;
                return counter;
              }
            };
    
        int numThreads = 10;
        int iterations = 1000;
        Thread[] threads = new Thread[numThreads];
        for (int i = 0; i < numThreads; i++) {
          threads[i] =
              new Thread() {
                @Override
                public void run() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 17.9K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java

              @Override
              public void run() {
                list.execute();
              }
            };
        Thread thread1 = new Thread(execute);
        Thread thread2 = new Thread(execute);
        thread1.start();
        thread2.start();
        assertEquals(0, runCalled.get());
        okayToRun.countDown();
        thread1.join();
        thread2.join();
        assertEquals(1, runCalled.get());
      }
    
      public void testAddAfterRun() throws Exception {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.7K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        start();
      }
    
      // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
      // so there is no object state put at risk by stopping the threads abruptly. In some cases a test
      // may put a thread into an uninterruptible operation intentionally, so there is no other way to
      // clean up these threads.
      @SuppressWarnings("deprecation")
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java

     * <p>
     * The context includes information such as the session ID, active thread count, access count, crawler status,
     * URL filter, rule manager, interval controller, robots.txt URL set, sitemaps, number of threads,
     * maximum thread check count, maximum depth, and maximum access count.
     * </p>
     *
     * <p>
     * It also provides thread-local storage for sitemaps, allowing each thread to have its own set of sitemaps.
     * </p>
     */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *
     * It is possible to cancel the finding process by canceling its call.
     *
     * Implementations of this interface are not thread-safe. Each instance is thread-confined to the
     * thread executing the call.
     */
    interface RoutePlanner {
      val address: Address
    
      /** Follow-ups for failed plans and plans that lost a race. */
      val deferredPlans: ArrayDeque<Plan>
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  8. api/maven-api-core/src/test/java/org/apache/maven/api/MonotonicClockTest.java

        void testMonotonicBehavior() throws InterruptedException {
            Instant first = MonotonicClock.now();
            Thread.sleep(10); // Small delay
            Instant second = MonotonicClock.now();
            Thread.sleep(10); // Small delay
            Instant third = MonotonicClock.now();
    
            assertTrue(first.isBefore(second), "Time should progress forward between measurements");
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Jan 15 06:28:29 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/internal/Finalizer.java

            logger.log(
                Level.INFO, "Failed to create a thread without inherited thread-local values", t);
          }
        }
        if (thread == null) {
          thread = new Thread((ThreadGroup) null, finalizer, threadName);
        }
        thread.setDaemon(true);
    
        try {
          if (inheritableThreadLocals != null) {
            inheritableThreadLocals.set(thread, null);
          }
        } catch (Throwable t) {
          logger.log(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/filter/UrlFilterTest.java

            urlFilter.init(sessionId);
    
            // Create multiple threads adding patterns
            Thread thread1 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
                    urlFilter.addInclude("https://site" + i + ".com/.*");
                }
            });
    
            Thread thread2 = new Thread(() -> {
                for (int i = 0; i < 100; i++) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 19K bytes
    - Viewed (0)
Back to top