- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 635 for Spread (0.03 sec)
-
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
assertThat(Thread.interrupted()).isTrue(); } public void testInterrupt_doesNotInterruptSubsequentTask() throws Exception { // Run a task that interrupts its thread (i.e. this thread). e.execute( new Runnable() { @Override public void run() { Thread.currentThread().interrupt(); } });
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 11.4K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
class Interruptenator extends Thread { final AtomicBoolean shutdown; Interruptenator(Thread interruptee) { this(interruptee, new AtomicBoolean(false)); } @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait. Interruptenator(Thread interruptee, AtomicBoolean shutdown) { super( new Runnable() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 7.9K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerContext.java
* <p> * The context includes information such as the session ID, active thread count, access count, crawler status, * URL filter, rule manager, interval controller, robots.txt URL set, sitemaps, number of threads, * maximum thread check count, maximum depth, and maximum access count. * </p> * * <p> * It also provides thread-local storage for sitemaps, allowing each thread to have its own set of sitemaps. * </p> */
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 8.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
} } /** Wait for the given thread to reach the {@link State#TIMED_WAITING} thread state. */ @SuppressWarnings("ThreadPriorityCheck") // TODO: b/175898629 - Consider onSpinWait. void awaitTimedWaiting(Thread thread) { while (true) { switch (thread.getState()) { case BLOCKED: case NEW: case RUNNABLE: case WAITING: Thread.yield(); break;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 28K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} } } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /** Invokes {@code toJoin.}{@link Thread#join() join()} uninterruptibly. */ @J2ktIncompatible @GwtIncompatible // concurrency public static void joinUninterruptibly(Thread toJoin) { boolean interrupted = false; try { while (true) { try {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.8K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
* thread) the subscriber is actually called when an event is dispatched to it. * * @author Colin Decker */ abstract class Dispatcher { /** * Returns a dispatcher that queues events that are posted reentrantly on a thread that is already * dispatching an event, guaranteeing that all events posted on a single thread are dispatched to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 7.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.21.md
- [Urgent Upgrade Notes](#urgent-upgrade-notes) - [(No, really, you MUST read this before you upgrade)](#no-really-you-must-read-this-before-you-upgrade) - [Changes by Kind](#changes-by-kind-13) - [Deprecation](#deprecation) - [API Change](#api-change-3) - [Feature](#feature-11)
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Fri Oct 14 07:03:14 UTC 2022 - 367.3K bytes - Viewed (0) -
guava-gwt/test-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/TestPlatform.java
assertThat(e).hasMessageThat().isEqualTo("Cannot get() on a pending future."); } } static void verifyThreadWasNotInterrupted() { // There is no thread interruption in GWT, so there's nothing to do. } static void clearInterrupt() { // There is no thread interruption in GWT, so there's nothing to do. } static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future)
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.3K bytes - Viewed (0) -
docs/contribute/concurrency.md
So we have a dedicated thread for every socket that just reads frames and dispatches them. The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedDequeTest.java
@Override public boolean offer(E o) { assertTrue(Thread.holdsLock(mutex)); return delegate.offer(o); } @Override public @Nullable E poll() { assertTrue(Thread.holdsLock(mutex)); return delegate.poll(); } @Override public E remove() { assertTrue(Thread.holdsLock(mutex)); return delegate.remove(); } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 7.4K bytes - Viewed (0)