- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 223 for nThreads (0.03 sec)
-
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) -
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) -
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) -
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) -
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. SeeRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 13 17:34:21 UTC 2025 - 4K bytes - Viewed (0) -
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 stringsRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon Jul 28 07:33:49 UTC 2025 - 3.6K bytes - Viewed (0) -
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) -
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 methodRegistered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 18.3K bytes - Viewed (0) -
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) -
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)