- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 177 for Runnable (0.04 sec)
-
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
* to any {@code Runnable} passed to the default implementation of {@link #wrapTask(Runnable)}. */ protected abstract <T extends @Nullable Object> Callable<T> wrapTask(Callable<T> callable); /** * Wraps a {@code Runnable} for submission to the underlying executor. The default implementation * delegates to {@link #wrapTask(Callable)}. */ protected Runnable wrapTask(Runnable command) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 5.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionList.java
+ runnable + " with executor " + executor, e); } } private static final class RunnableExecutorPair { final Runnable runnable; final Executor executor; @Nullable RunnableExecutorPair next; RunnableExecutorPair(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
+ runnable + " with executor " + executor, e); } } private static final class RunnableExecutorPair { final Runnable runnable; final Executor executor; @Nullable RunnableExecutorPair next; RunnableExecutorPair(
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
@Override public void execute(Runnable runnable) { assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class); runnable.run(); } @Override public void shutdown() {} @Override public List<Runnable> shutdownNow() { return ImmutableList.of(); } @Override public boolean isShutdown() { return false; } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
@Override public void execute(Runnable runnable) { assertThat(runnable).isInstanceOf(TrustedListenableFutureTask.class); runnable.run(); } @Override public void shutdown() {} @Override public List<Runnable> shutdownNow() { return ImmutableList.of(); } @Override public boolean isShutdown() { return false; } @Override
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
} @JvmStatic fun threadFactory(name: String): ThreadFactory = object : ThreadFactory { private var nextId = 1 override fun newThread(runnable: Runnable): Thread = Thread(runnable, "$name-${nextId++}") } } fun getEnv(name: String) = System.getenv(name) val SYSTEM_FILE_SYSTEM = FileSystem.SYSTEM
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 4.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
} runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute = new Runnable() { @Override public void run() { list.execute(); } }; Thread thread1 = new Thread(execute); Thread thread2 = new Thread(execute); thread1.start(); thread2.start();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
} runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute = new Runnable() { @Override public void run() { list.execute(); } }; Thread thread1 = new Thread(execute); Thread thread2 = new Thread(execute); thread1.start(); thread2.start();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 4.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerRealBackendTest.kt
private val loggingUncaughtExceptionHandler = UncaughtExceptionHandler { _, throwable -> log.put("uncaught exception: $throwable") } private val threadFactory = ThreadFactory { runnable -> Thread(runnable, "TaskRunnerRealBackendTest").apply { isDaemon = true uncaughtExceptionHandler = loggingUncaughtExceptionHandler } } private val backend = TaskRunner.RealBackend(threadFactory)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
Runnable runnable, @ParametricNullness V result) { return new ListenableFutureTask<>(runnable, result); } ListenableFutureTask(Callable<V> callable) { super(callable); } ListenableFutureTask(Runnable runnable, @ParametricNullness V result) { super(runnable, result); } @Override public void addListener(Runnable listener, Executor exec) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 4.2K bytes - Viewed (0)