- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 239 for runnable (0.89 seconds)
-
android/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) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 4.2K bytes - Click Count (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(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 10 11:51:21 GMT 2026 - 6.9K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Runnables.java
*/ @SuppressWarnings({"InlineLambdaConstant", "UnnecessaryLambda"}) private static final Runnable EMPTY_RUNNABLE = () -> {}; /** Returns a {@link Runnable} instance that does nothing when run. */ public static Runnable doNothing() { return EMPTY_RUNNABLE; } private Runnables() {}Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Aug 05 15:30:14 GMT 2025 - 1.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeLimiter.java
* @throws UncheckedExecutionException if {@code runnable} throws a {@code RuntimeException} * @throws ExecutionError if {@code runnable} throws an {@code Error} * @since 22.0 */ void runWithTimeout(Runnable runnable, long timeoutDuration, TimeUnit timeoutUnit) throws TimeoutException, InterruptedException; /** * Invokes a specified Runnable, timing out after the specified time limit. If the target methodCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 8.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
} @Override public T call() throws Exception { return delegate.call(); } } private static final class WrappedRunnable implements Runnable { private final Runnable delegate; WrappedRunnable(Runnable delegate) { this.delegate = delegate; } @Override public void run() { delegate.run(); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
} @Override public T call() throws Exception { return delegate.call(); } } private static final class WrappedRunnable implements Runnable { private final Runnable delegate; WrappedRunnable(Runnable delegate) { this.delegate = delegate; } @Override public void run() { delegate.run(); } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
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) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor( Runnable runnable, @ParametricNullness T value) { return TrustedListenableFutureTask.create(runnable, value); } /** * @since 19.0 (present with return type {@code ListenableFutureTask} since 14.0) */ @CanIgnoreReturnValue // TODO(kak): consider removing this
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Feb 12 17:47:46 GMT 2025 - 3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
* Runnable}, and arrange that {@code get} will return the given result on successful completion. * * @param runnable the runnable task * @param result the result to return on successful completion. If you don't need a particular * result, consider using constructions of the form: {@code ListenableFuture<?> f = * ListenableFutureTask.create(runnable, null)} */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri Jul 11 18:52:30 GMT 2025 - 5.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/eventbus/AsyncEventBusTest.java
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 2.4K bytes - Click Count (0)