Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 223 for nThreads (0.03 sec)

  1. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            return jobProcess != null && jobProcess.getProcess().isAlive();
        }
    
        /**
         * Internal method to destroy a specific JobProcess.
         * Handles cleanup of streams, threads, and process termination.
         *
         * @param sessionId unique identifier for the process session
         * @param jobProcess the JobProcess to destroy
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Nov 20 06:54:47 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  2. 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}.
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 10 04:56:21 UTC 2025
    - 12.8K bytes
    - Viewed (0)
  3. 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) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Feb 10 21:03:40 UTC 2025
    - 2.8K bytes
    - Viewed (0)
  4. 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);
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Sep 17 10:01:14 UTC 2025
    - 30.9K bytes
    - Viewed (0)
  5. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 17:34:21 UTC 2025
    - 4K bytes
    - Viewed (0)
  6. 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
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  7. 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
        }
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Fri Nov 28 16:29:12 UTC 2025
    - 25K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerThreadTest.java

            crawlerThread.run();
    
            verify(intervalController, times(1)).delay(IntervalController.NO_URL_IN_QUEUE);
        }
    
        /**
         * Test isContinue with active threads still running.
         */
        public void test_isContinue_withActiveThreads() throws Exception {
            crawlerContext.setActiveThreadCount(2);
    
            // Use reflection to access protected method
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Mon Nov 24 03:59:47 UTC 2025
    - 18.3K bytes
    - Viewed (0)
  9. 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;
    
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  10. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
Back to top