- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 10 for ListenableScheduledFuture (0.17 seconds)
-
android/guava/src/com/google/common/util/concurrent/ListenableScheduledFuture.java
/** * Helper interface to implement both {@link ListenableFuture} and {@link ScheduledFuture}. * * @author Anthony Zana * @since 15.0 */ @GwtCompatible public interface ListenableScheduledFuture<V extends @Nullable Object>Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ListeningScheduledExecutorServiceTest.java
} private static class ImmediateScheduledFuture<V> extends SimpleForwardingListenableFuture<V> implements ListenableScheduledFuture<V> { static <V> ListenableScheduledFuture<V> of(V value) { return new ImmediateScheduledFuture<>(immediateFuture(value)); } static <V> ListenableScheduledFuture<V> failed(Throwable t) { return new ImmediateScheduledFuture<>(immediateFailedFuture(t)); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 6.5K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
} @Override public void execute(Runnable runnable) {} @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ListeningScheduledExecutorService.java
/** * @since 15.0 (previously returned ScheduledFuture) */ @Override ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit); /** * @since 15.0 (previously returned ScheduledFuture) */ @Override <V extends @Nullable Object> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit); /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Feb 11 17:30:04 GMT 2025 - 2.1K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { Preconditions.checkNotNull(command, "command must not be null"); Preconditions.checkNotNull(unit, "unit must not be null!"); return schedule(callable(command), delay, unit); } @Override public <V> ListenableScheduledFuture<V> schedule(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { Preconditions.checkNotNull(command, "command must not be null"); Preconditions.checkNotNull(unit, "unit must not be null!"); return schedule(callable(command), delay, unit); } @Override public <V> ListenableScheduledFuture<V> schedule(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:37:28 GMT 2025 - 6.5K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
} @Override public void execute(Runnable runnable) {} @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
ScheduledListeningDecorator(ScheduledExecutorService delegate) { super(delegate); this.delegate = checkNotNull(delegate); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { TrustedListenableFutureTask<@Nullable Void> task = TrustedListenableFutureTask.create(command, null);Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
// caught and forwarded to the service the task would stop executing but the service would // have no idea. // TODO(lukes): consider building everything in terms of ListenableScheduledFuture then // the AbstractService could monitor the future directly. Rescheduling is still hard... // but it would help with some of these lock ordering issues. scheduleFailure = e;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
*/ @J2ktIncompatible @GwtIncompatible // java.util.concurrent.ScheduledExecutorService @IgnoreJRERequirement // Users will use this only if they're already using Duration. // TODO(cpovirk): Return ListenableScheduledFuture? public static <O extends @Nullable Object> ListenableFuture<O> scheduleAsync( AsyncCallable<O> callable, Duration delay, ScheduledExecutorService executorService) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0)