Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 216 for Threads (0.07 seconds)

  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/org/codelibs/fess/mylasta/direction/sponsor/FessSecurityResourceProviderTest.java

                final int index = i;
                threads[i] = new Thread(() -> {
                    invertibles[index] = securityResourceProvider.providePrimaryInvertibleCryptographer();
                    oneWays[index] = securityResourceProvider.providePrimaryOneWayCryptographer();
                });
                threads[i].start();
            }
    
            // Wait for all threads to complete
            for (Thread thread : threads) {
                try {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Mar 13 23:01:26 GMT 2026
    - 13.2K bytes
    - Click Count (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top