Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 754 for Threads (0.05 seconds)

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

  1. src/test/java/org/codelibs/fess/ds/AbstractDataStoreTest.java

                        exceptions[index] = e;
                    }
                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Verify no exceptions occurred
            for (int i = 0; i < threadCount; 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)
  2. 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)
  3. src/test/java/jcifs/smb/SmbSessionImplSecurityTest.java

            // When - Multiple threads accessing trees concurrently
            for (int t = 0; t < threadCount; t++) {
                final int threadId = t;
                executor.submit(() -> {
                    try {
                        startLatch.await(); // Wait for all threads to be ready
    
                        for (int i = 0; i < opsPerThread; i++) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 11K bytes
    - Click Count (0)
  4. src/main/java/jcifs/smb1/smb1/TestLocking.java

                } else {
                    t.url = args[ai];
                }
            }
    
            final Thread[] threads = new Thread[t.numThreads];
            int ti;
    
            for (ti = 0; ti < t.numThreads; ti++) {
                threads[ti] = new Thread(t);
                logger.info(threads[ti].getName());
                threads[ti].start();
            }
    
            while (t.numComplete < t.numThreads) {
                long delay;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 4.2K bytes
    - Click Count (0)
  5. 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)
  6. src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTest.java

                        Thread.currentThread().interrupt();
                    }
                });
            }
    
            // Start all threads
            for (Thread t : threads) {
                t.start();
            }
    
            // Wait for all threads to complete
            for (Thread t : threads) {
                t.join();
            }
    
            // Verify password is wiped
            assertNull(auth.getPassword());
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 23.3K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImplTest.java

                    }
                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Verify no exceptions occurred
            for (int i = 0; i < threadCount; i++) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 19.7K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

      /**
       * When we need a new thread to run tasks, we call [Backend.execute]. A few microseconds later we
       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
       * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sat Aug 30 11:30:11 GMT 2025
    - 10.4K bytes
    - Click Count (0)
  9. src/test/java/jcifs/util/SimpleCircuitBreakerTest.java

                        }
                    }
                });
            }
    
            // Start all threads
            for (Thread t : threads) {
                t.start();
            }
    
            // Wait for completion
            for (Thread t : threads) {
                t.join();
            }
    
            // Verify consistency
            SimpleCircuitBreaker.Statistics stats = breaker.getStatistics();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 10.6K bytes
    - Click Count (0)
  10. android/guava-tests/benchmark/com/google/common/util/concurrent/MoreExecutorsDirectExecutorBenchmark.java

                  }
                  countingRunnable.integer.addAndGet(localRunnable.integer.get());
                }
              };
          threads.add(thread);
        }
      }
    
      @AfterExperiment
      void after() {
        for (Thread thread : threads) {
          thread.interrupt(); // try to get them to exit
        }
        threads.clear();
      }
    
      @Footprint
      Object measureSize() {
        return executor;
      }
    
      @Benchmark
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3.4K bytes
    - Click Count (0)
Back to Top