Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 341 - 350 of 648 for threadId (0.08 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                        break;
                    }
                    Thread.sleep(50);
                }
                assertEquals(CrawlerStatus.RUNNING, crawler1.crawlerContext.getStatus());
                for (int i = 0; i < 100; i++) {
                    if (crawler2.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
                        break;
                    }
                    Thread.sleep(50);
                }
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Jan 15 01:11:43 GMT 2026
    - 7.8K bytes
    - Click Count (0)
  2. src/test/java/org/codelibs/curl/io/IOIntegrationTest.java

            assertNotNull(threadName.get());
            // The async execution should have run on a ForkJoinPool thread, not the main thread
            assertTrue("Should run on ForkJoinPool thread: " + threadName.get(),
                    threadName.get().contains("ForkJoinPool") || !threadName.get().equals(Thread.currentThread().getName()));
            pool.shutdown();
        }
    
        // --- Synchronous execute() test ---
    
        @Test
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Sat Mar 21 12:00:34 GMT 2026
    - 44.1K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/eventbus/Subscriber.java

      /**
       * Checks whether {@code method} is thread-safe, as indicated by the presence of the {@link
       * AllowConcurrentEvents} annotation.
       */
      private static boolean isDeclaredThreadSafe(Method method) {
        return method.getAnnotation(AllowConcurrentEvents.class) != null;
      }
    
      /**
       * Subscriber that synchronizes invocations of a method to ensure that only one thread may enter
       * the method at a time.
       */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/ForwardingSortedSet.java

     * violate the {@code Set} contract.
     *
     * <p>The {@code standard} methods and the collection views they return are not guaranteed to be
     * thread-safe, even when all of the methods that they depend on are thread-safe.
     *
     * @author Mike Bostock
     * @author Louis Wasserman
     * @since 2.0
     */
    @GwtCompatible
    /*
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Feb 12 16:28:01 GMT 2025
    - 5.7K bytes
    - Click Count (0)
  5. src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java

            }
    
            // Initialize the digest once to validate configuration
            this.digest = createMacInstance();
        }
    
        /**
         * Create a new Mac instance for thread-safe operations
         * @return initialized Mac instance
         * @throws GeneralSecurityException if Mac cannot be created
         */
        private Mac createMacInstance() throws GeneralSecurityException {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  6. okhttp-testing-support/src/main/kotlin/okhttp3/EventRecorder.kt

      private val forbiddenLocks = mutableListOf<Any>()
    
      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 4.5K bytes
    - Click Count (0)
  7. impl/maven-core/src/main/java/org/apache/maven/DefaultMaven.java

            ClassLoader originalClassLoader = Thread.currentThread().getContextClassLoader();
            try {
                for (AbstractMavenLifecycleParticipant listener :
                        getExtensionComponents(session.getProjects(), AbstractMavenLifecycleParticipant.class)) {
                    Thread.currentThread().setContextClassLoader(listener.getClass().getClassLoader());
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Mon Dec 29 10:43:38 GMT 2025
    - 28.8K bytes
    - Click Count (1)
  8. src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java

     * <li>{@link #analyzer} - Suggest analyzer.</li>
     * <li>{@link #contentsParser} - Contents parser.</li>
     * <li>{@link #suggestWriter} - Suggest writer.</li>
     * <li>{@link #threadPool} - Executor service for thread pool.</li>
     * </ul>
     */
    public class SuggestIndexer {
        private final static Logger logger = LogManager.getLogger(SuggestIndexer.class);
    
        /** The suggest analyzer. */
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sat Mar 14 02:35:38 GMT 2026
    - 20.9K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java

      private Thread executionThread;
      private Throwable thrownByExecutionThread;
      private final Executor exceptionCatchingExecutor =
          new Executor() {
            @Override
            public void execute(Runnable command) {
              executionThread = new Thread(command);
              executionThread.setUncaughtExceptionHandler(
                  (thread, throwable) -> thrownByExecutionThread = throwable);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 12.8K bytes
    - Click Count (0)
  10. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

     * invoke methods, they invoke methods on the {@code ForwardingBlockingDeque}.
     *
     * <p>The {@code standard} methods are not guaranteed to be thread-safe, even when all of the
     * methods that they depend on are thread-safe.
     *
     * @author Emily Soldal
     * @since 14.0
     * @deprecated This class has moved to {@code com.google.common.util.concurrent}. Please use {@link
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 4.3K bytes
    - Click Count (0)
Back to Top