Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 232 for nThreads (0.05 seconds)

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

  1. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

                        doneLatch.countDown();
                    }
                }).start();
            }
    
            startLatch.countDown(); // Start all threads
            assertTrue("All threads should complete", doneLatch.await(10, TimeUnit.SECONDS));
    
            Thread.sleep(100); // Wait for callback to execute
    
            assertEquals("Only one resolve should succeed", 1, callbackCount.get());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 21.1K bytes
    - Click Count (0)
  2. compat/maven-embedder/src/test/java/org/apache/maven/cli/MavenCliTest.java

            cli.initialize(request);
            cli.cli(request);
            assertEquals("multithreaded", request.commandLine.getOptionValue(CLIManager.BUILDER));
            assertEquals("8", request.commandLine.getOptionValue(CLIManager.THREADS));
    
            // override from command line
            request = new CliRequest(new String[] {"--builder", "foobar"}, null);
            cli.cli(request);
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Sep 17 10:01:14 GMT 2025
    - 30.9K bytes
    - Click Count (0)
  3. src/main/resources/fess_message_pt_BR.properties

    errors.could_not_delete_logged_in_user=Não é possível excluir o usuário logado.
    errors.unauthorized_request=Solicitação não autorizada.
    errors.failed_to_print_thread_dump=Não foi possível imprimir o despejo de threads.
    errors.file_is_not_supported={0} não é suportado.
    errors.plugin_file_is_not_found={0} não encontrado.
    errors.failed_to_install_plugin=Não foi possível instalar {0}.
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 13.7K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java

      private UncaughtExceptionHandlers() {}
    
      /**
       * Returns an exception handler that exits the system. This is particularly useful for the main
       * thread, which may start up other, non-daemon threads, but fail to fully initialize the
       * application successfully.
       *
       * <p>Example usage:
       *
       * <pre>
       * public static void main(String[] args) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 10 21:03:40 GMT 2025
    - 2.8K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionError.java

     * ExecutionException} or {@link UncheckedExecutionException}. This allows the client code to
     * continue to distinguish between exceptions and errors, even when they come from other threads.
     *
     * @author Chris Povirk
     * @since 10.0
     */
    @GwtCompatible
    public class ExecutionError extends Error {
      /*
       * Ideally, this class would have exposed only constructors that require a non-null cause. See
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 13 17:34:21 GMT 2025
    - 4K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/helper/WebFsIndexHelper.java

    /**
     * Helper class for web and file system crawling and indexing operations.
     * Manages the crawling process for both web configurations and file configurations,
     * coordinating multiple crawler threads and handling indexing operations.
     */
    public class WebFsIndexHelper {
    
        /**
         * Default constructor.
         */
        public WebFsIndexHelper() {
            // Default constructor
        }
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 25K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

    internal abstract class BasePublicSuffixList : PublicSuffixList {
      /** True after we've attempted to read the list for the first time. */
      private val listRead = AtomicBoolean(false)
    
      /** Used for concurrent threads reading the list for the first time. */
      private val readCompleteLatch = CountDownLatch(1)
    
      // The lists are held as a large array of UTF-8 bytes. This is to avoid allocating lots of strings
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 28 07:33:49 GMT 2025
    - 3.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/app/web/admin/fileconfig/CreateForm.java

        @Min(value = 0)
        @Max(value = 9223372036854775807L)
        @ValidateTypeFailure
        public Long maxAccessCount;
    
        /** The number of threads to use for crawling (required, 1 to 2147483647). */
        @Required
        @Min(value = 1)
        @Max(value = 2147483647)
        @ValidateTypeFailure
        public Integer numOfThread;
    
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.6K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

                task.run();
                awaitUnchecked(barrier);
              };
          for (int j = 0; j < 10; j++) {
            executor.execute(wrapper);
          }
          barrier.await(); // release the threads!
          barrier.await(); // wait for them all to complete
          assertEquals(1, task.get().intValue());
          assertEquals(1, counter.get());
        }
        executor.shutdown();
      }
    
      @J2ktIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.5K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/app/web/admin/webconfig/CreateForm.java

        /**
         * The user agent string to use during crawling.
         */
        @Required
        @Size(max = 200)
        public String userAgent;
    
        /**
         * The number of crawler threads to use.
         */
        @Required
        @Min(value = 1)
        @Max(value = 2147483647)
        @ValidateTypeFailure
        public Integer numOfThread;
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Jul 17 08:28:31 GMT 2025
    - 5.9K bytes
    - Click Count (0)
Back to Top