- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 232 for nThreads (0.05 seconds)
-
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
Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Nov 20 06:54:47 GMT 2025 - 10.9K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java
protected String propertiesPath; /** * Number of threads to use for thumbnail generation. */ @Option(name = "-t", aliases = "--numOfThreads", metaVar = "numOfThreads", usage = "The number of threads") protected int numOfThreads = 1; /** * Whether to run in cleanup mode to remove old thumbnails. */Created: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 9.4K bytes - Click Count (0) -
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 Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Feb 10 21:03:40 GMT 2025 - 2.8K bytes - Click Count (0) -
fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/client/FesenClientTest.java
mockClient = mock(Client.class); fesenClient.client = mockClient; } /** * Test: Thread-safe listener management using CopyOnWriteArrayList * Verifies that multiple threads can safely add listeners concurrently */ @Test public void testThreadSafeListenerManagement() throws Exception { final int numThreads = 10;
Created: Sat Dec 20 11:21:39 GMT 2025 - Last Modified: Thu Nov 20 08:44:44 GMT 2025 - 17K bytes - Click Count (0) -
src/main/java/org/codelibs/core/collection/LruHashMap.java
* <p> * <strong>Thread-Safety:</strong> This class is <strong>NOT thread-safe</strong>. * It extends {@link LinkedHashMap} without synchronization. If multiple threads access * an instance concurrently, and at least one thread modifies the map structurally, * it must be synchronized externally. * </p> * <p>
Created: Sat Dec 20 08:55:33 GMT 2025 - Last Modified: Sat Nov 22 11:21:59 GMT 2025 - 3K bytes - Click Count (0) -
src/test/java/jcifs/smb/NtlmPasswordAuthenticatorTimingAttackTest.java
} }); } executor.shutdown(); assertTrue(executor.awaitTermination(30, TimeUnit.SECONDS), "All threads should complete within timeout"); // Analyze timing consistency across threads if (!timings.isEmpty()) { double avgTime = timings.stream().mapToLong(Long::longValue).average().orElse(0.0);Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 11.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
long count; } private static final int ITERATION_COUNT = 50_000; private static final int DIRECT_EXECUTIONS_PER_THREAD = 100; @J2ktIncompatible @GwtIncompatible // threads public void testAvoidsStackOverflow_multipleThreads() throws Exception { LongHolder holder = new LongHolder(); ArrayList<ListenableFuture<Integer>> lengthChecks = new ArrayList<>();
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 16.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
/** * Plans currently being connected, and that will later be added to [connectResults]. This is * mutated by the call thread only. If is accessed by background connect threads. */ private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>() /** * Results are posted here as they occur. The find job is done when either one plan completes * successfully or all plans fail. */
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 5.8K 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: Sat Dec 20 09:19:18 GMT 2025 - Last Modified: Thu Jul 10 04:56:21 GMT 2025 - 12.8K 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 Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Feb 10 21:03:40 GMT 2025 - 2.8K bytes - Click Count (0)