- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 692 for threadId (0.04 sec)
-
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> * For thread-safe usage, wrap with {@link java.util.Collections#synchronizedMap(Map)}:
Registered: Sat Dec 20 08:55:33 UTC 2025 - Last Modified: Sat Nov 22 11:21:59 UTC 2025 - 3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.2K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/net/protocol/storage/HandlerTest.java
} }).start(); } // Signal all threads to start at once startLatch.countDown(); // Wait for all threads to complete assertTrue("Threads did not complete in time", doneLatch.await(5, TimeUnit.SECONDS)); // All threads should fail with the same IOException (endpoint is blank)Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Thu Dec 11 08:38:29 UTC 2025 - 14.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
@Override public Integer call() { return Thread.currentThread().getStackTrace().length; } }, directExecutor()); settableFuture.set(null); assertThat(getDone(stackDepthCheck)) .isLessThan(Thread.currentThread().getStackTrace().length + 100); }Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 16.2K bytes - Viewed (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> *
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Feb 10 21:03:40 UTC 2025 - 2.8K bytes - Viewed (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();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (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(
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 9.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/api/admin/stats/ApiAdminStatsAction.java
return jvmGcObj; }).toArray(n -> new JvmGcObj[n]); final Threads threads = jvmStats.getThreads(); final JvmThreadsObj jvmThreadsObj = new JvmThreadsObj(); jvmObj.threads = jvmThreadsObj; jvmThreadsObj.count = threads.getCount(); jvmThreadsObj.peak = threads.getPeakCount(); final Classes classes = jvmStats.getClasses();Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 19.7K bytes - Viewed (0) -
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();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/CacheLoadingTest.java
} }); thread.start(); // we want to wait until each thread is WAITING - one thread waiting inside CacheLoader.load // (in startSignal.await()), and the others waiting for that thread's result. while (thread.isAlive() && thread.getState() != Thread.State.WAITING) { Thread.yield(); } } gettersStartedSignal.countDown();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 30 22:03:28 UTC 2025 - 91.1K bytes - Viewed (0)