- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 154 for runnable (0.04 sec)
-
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances // and DONE/INTERRUPTED - they have a common ancestor of Runnable. abstract class InterruptibleTask<T extends @Nullable Object> extends AtomicReference<@Nullable Runnable> implements Runnable { static { // Prevent rare disastrous classloading in first call to LockSupport.park. // See: https://bugs.openjdk.org/browse/JDK-8074773
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
private val busyQueues = mutableListOf<TaskQueue>() /** Queues not in [busyQueues] that have non-empty [TaskQueue.futureTasks]. */ private val readyQueues = mutableListOf<TaskQueue>() private val runnable: Runnable = object : Runnable { override fun run() { var task: Task = withLock { runCallCount++ awaitTaskToRun() } ?: return
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:30:11 UTC 2025 - 10.4K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/google/ReflectionFreeAssertThrows.java
} @CanIgnoreReturnValue static <T extends Throwable> T assertThrows( Class<T> expectedThrowable, ThrowingRunnable runnable) { return doAssertThrows( expectedThrowable, () -> { runnable.run(); return null; }, /* userPassedSupplier= */ false); } private static <T extends Throwable> T doAssertThrows(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 6.3K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
} @Override public <T> ListenableFuture<T> submit(Runnable task, T result) { Preconditions.checkNotNull(task, "task must not be null!"); Preconditions.checkNotNull(result, "result must not be null!"); return delegate.submit(task, result); } @Override public ListenableFuture<?> submit(Runnable task) { Preconditions.checkNotNull(task, "task must not be null!");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
} @Override public <T> ListenableFuture<T> submit(Runnable task, T result) { Preconditions.checkNotNull(task, "task must not be null!"); Preconditions.checkNotNull(result, "result must not be null!"); return delegate.submit(task, result); } @Override public ListenableFuture<?> submit(Runnable task) { Preconditions.checkNotNull(task, "task must not be null!");
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 6.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* otherwise-concurrent GC cycle. */ private static final class TaskNonReentrantExecutor extends AtomicReference<RunningState> implements Executor, Runnable { /** * Used to update and read the latestTaskQueue field. Set to null once the runnable has been run * or queued. */ @Nullable ExecutionSequencer sequencer; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 23 15:26:56 UTC 2025 - 22.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
} @Test fun interruptStopsThread() { val taskRunnerThreads = mutableListOf<Thread>() val taskRunner = TaskRunner( RealBackend { runnable -> Thread(runnable, "interruptStopsThread TaskRunner") .also { taskRunnerThreads += it } }, ) val pool = factory.newConnectionPool( taskRunner = taskRunner,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 12.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java
public Integer call() { return counter.incrementAndGet(); } }); CyclicBarrier barrier = new CyclicBarrier(numThreads + 1); Runnable wrapper = new Runnable() { @Override public void run() { awaitUnchecked(barrier); task.run(); awaitUnchecked(barrier); } };
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 7.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
*/ protected ScheduledExecutorService executor() { @WeakOuter final class ThreadFactoryImpl implements ThreadFactory { @Override public Thread newThread(Runnable runnable) { return MoreExecutors.newThread(serviceName(), runnable); } } ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/AbstractTester.java
* @author George van den Driessche */ @GwtCompatible @NullMarked public class AbstractTester<G> extends TestCase { private G subjectGenerator; private String suiteName; private @Nullable Runnable setUp; private @Nullable Runnable tearDown; // public so that it can be referenced in generated GWT tests. @Override public void setUp() throws Exception { if (setUp != null) { setUp.run(); } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 3.3K bytes - Viewed (0)