- Sort Score
- Num 10 results
- Language All
Results 101 - 110 of 232 for nThreads (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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. SeeCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 13 17:34:21 GMT 2025 - 4K bytes - Click Count (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 }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 25K bytes - Click Count (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 stringsCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Mon Jul 28 07:33:49 GMT 2025 - 3.6K bytes - Click Count (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;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) -
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) -
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)