Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 203 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/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)
  2. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

       * intentionally, so there is no other way to clean up these threads. (The better solution,
       * though, would be to run the tests that use TestThread in separate VMs so that their threads
       * don't hang around during other tests.)
       */
      @Override
      public void tearDown() throws Exception {
        try {
          Thread.class.getMethod("stop").invoke(this);
          join();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 11.5K bytes
    - Click Count (0)
  3. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessTimeResourceProviderTest.java

            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // Check all providers were created successfully
            for (int i = 0; i < threadCount; i++) {
                assertNull(exceptions[i], "Thread " + i + " threw exception");
                assertNotNull(providers[i], "Thread " + i + " failed to create provider");
            }
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 17.8K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            () -> {
              assertThat(Thread.currentThread().getName()).isEqualTo(newName.get());
              return null;
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // threads
      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            () -> {
              assertThat(Thread.currentThread().getName()).isEqualTo(newName.get());
              return null;
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4K bytes
    - Click Count (0)
  6. src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainFinallyHookTest.java

                    }
                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join(5000); // 5 second timeout
            }
    
            // Verify no errors occurred during concurrent execution
            assertFalse(hasError.get());
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 8.7K bytes
    - Click Count (0)
  7. 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)
  8. src/test/java/org/codelibs/fess/mylasta/direction/FessConfigImplTest.java

                });
            }
    
            // Start all threads
            for (Thread thread : threads) {
                thread.start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                thread.join();
            }
    
            // All results should be the same
            String expectedValue = "Test Fess";
            for (String result : results) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 12.9K bytes
    - Click Count (0)
  9. 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)
  10. android/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)
Back to Top