Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 383 for Thread (0.04 seconds)

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

        thread.start();
        thread.join();
        assertTrue(completed);
    
        // Creating a new thread from the same ThreadFactory will have the same
        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
        checkThreadPoolName(thread2, 2);
        assertThat(thread2.getName().substring(0, thread.getName().lastIndexOf('-')))
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.8K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        thread.start();
        thread.join();
        assertTrue(completed);
    
        // Creating a new thread from the same ThreadFactory will have the same
        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
        checkThreadPoolName(thread2, 2);
        assertThat(thread2.getName().substring(0, thread.getName().lastIndexOf('-')))
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.8K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

                });
            }
    
            for (Thread thread : threads) {
                thread.start();
            }
    
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Verify no exceptions
            for (int i = 0; i < threadCount; i++) {
                assertNull(exceptions[i], "Thread " + i + " threw exception");
                assertEquals("Thread " + i + " got wrong name", "Test", results[i]);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.8K bytes
    - Click Count (1)
  4. src/test/java/org/codelibs/fess/util/ThreadDumpUtilTest.java

            // Verify that thread dump was processed
            assertFalse("Should capture some thread dump output", capturedOutput.isEmpty());
    
            // Verify format - should contain "Thread:" entries
            boolean hasThreadEntry = capturedOutput.stream().anyMatch(line -> line.startsWith("Thread:"));
            assertTrue("Should contain Thread: entries", hasThreadEntry);
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 15.6K bytes
    - Click Count (0)
  5. 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(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 03:19:29 GMT 2026
    - 9.6K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *   <li>a {@linkplain ThreadFactoryBuilder#setNameFormat naming format}
     *   <li>a {@linkplain Thread#setPriority thread priority}
     *   <li>an {@linkplain Thread#setUncaughtExceptionHandler uncaught exception handler}
     *   <li>a {@linkplain ThreadFactory#newThread backing thread factory}
     * </ul>
     *
     * <p>If no backing thread factory is provided, a default backing thread factory is used as if by
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 29 17:36:00 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/ds/DataStoreFactoryTest.java

            // Multiple threads read the lastLoadedTime
            for (int i = 0; i < 10; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    observedTimes[index] = testFactory.lastLoadedTime;
                });
            }
    
            for (Thread thread : threads) {
                thread.start();
            }
    
            for (Thread thread : threads) {
                thread.join();
            }
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 18.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      /** Returns a new started daemon Thread running the given runnable. */
      final Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
       * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (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(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 03:19:29 GMT 2026
    - 9.6K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

        // isn't currently executing this task.
        Runnable currentRunner = get();
        if (currentRunner instanceof Thread) {
          Blocker blocker = new Blocker(this);
          blocker.setOwner(Thread.currentThread());
          if (compareAndSet(currentRunner, blocker)) {
            // Thread.interrupt can throw arbitrary exceptions due to the nio InterruptibleChannel API
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
Back to Top