- Sort Score
- Num 10 results
- Language All
Results 91 - 100 of 805 for threadId (0.19 seconds)
-
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
}); assertFalse(task.isDone()); Thread thread = new Thread( () -> { try { task.run(); } finally { exitLatch.countDown(); } }, "Custom thread name"); thread.start(); enterLatch.await(); assertFalse(task.isDone());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) -
README.md
service.setPort(9200); }); ``` ## Performance Tuning ### Thread Configuration ```java // Optimize thread pool settings crawler.crawlerContext.setNumOfThread(20); // Number of crawler threads crawler.crawlerContext.setMaxThreadCheckCount(50); // Thread monitoring frequency ``` ### Connection Pool Tuning ```java
Created: Sun Apr 12 03:50:13 GMT 2026 - Last Modified: Sun Aug 31 05:32:52 GMT 2025 - 15.3K bytes - Click Count (0) -
guava/src/com/google/common/cache/LoadingCache.java
* instances is using {@link CacheBuilder}. * * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed * by multiple concurrent threads. * * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link * #getUnchecked}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
} ListenableFuture<Integer> stackDepthCheck = serializer.submit(() -> Thread.currentThread().getStackTrace().length, directExecutor()); settableFuture.set(null); assertThat(getDone(stackDepthCheck)) .isLessThan(Thread.currentThread().getStackTrace().length + 100); } public void testAvoidsStackOverflow_alternatingCancelledAndSubmitted() throws Exception {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
}); assertFalse(task.isDone()); Thread thread = new Thread( () -> { try { task.run(); } finally { exitLatch.countDown(); } }, "Custom thread name"); thread.start(); enterLatch.await(); assertFalse(task.isDone());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) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
assertFalse(future.isDone()); assertFalse(future.isCancelled()); CountDownLatch successLatch = new CountDownLatch(1); // Run cancellation in a separate thread as an extra thread-safety test. new Thread( () -> { assertThrows(CancellationException.class, future::get); successLatch.countDown(); }) .start();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 6.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/UncaughtExceptionHandlers.java
/** * 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) { * Thread.currentThread().setUncaughtExceptionHandler(UncaughtExceptionHandlers.systemExit()); * ... * </pre> *
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/base/internal/Finalizer.java
logger.log( Level.INFO, "Failed to create a thread without inherited thread-local values", t); } } if (thread == null) { thread = new Thread((ThreadGroup) null, finalizer, threadName); } thread.setDaemon(true); try { if (inheritableThreadLocals != null) { inheritableThreadLocals.set(thread, null); } } catch (Throwable t) { logger.log(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 11 03:19:29 GMT 2026 - 9.6K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LoadingCache.java
* instances is using {@link CacheBuilder}. * * <p>Implementations of this interface are expected to be thread-safe, and can be safely accessed * by multiple concurrent threads. * * <p>When evaluated as a {@link Function}, a cache yields the same result as invoking {@link * #getUnchecked}. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 03 12:40:22 GMT 2026 - 8.5K bytes - Click Count (0) -
src/test/java/jcifs/smb/PreauthIntegrityTest.java
fail("Thread failed: " + e.getMessage()); } finally { doneLatch.countDown(); } }); } // Start all threads at once startLatch.countDown(); // Wait for completion assertTrue(doneLatch.await(5, TimeUnit.SECONDS), "Threads did not complete in time"); executor.shutdown();
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 10.5K bytes - Click Count (0)