- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for withTimeout (0.08 sec)
-
guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java
assertThat(f.get()).isEqualTo(2); } @J2ktIncompatible @GwtIncompatible // withTimeout public void testWithTimeout() throws Exception { ScheduledExecutorService executor = newScheduledThreadPool(1); try { FluentFuture<?> f = FluentFuture.from(SettableFuture.create()).withTimeout(0, SECONDS, executor); ExecutionException e = assertThrows(ExecutionException.class, () -> f.get());
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 17:50:58 UTC 2025 - 5.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
@GwtIncompatible // ScheduledExecutorService @IgnoreJRERequirement // Users will use this only if they're already using Duration. public final FluentFuture<V> withTimeout( Duration timeout, ScheduledExecutorService scheduledExecutor) { return withTimeout(toNanosSaturated(timeout), TimeUnit.NANOSECONDS, scheduledExecutor); } /** * Returns a future that delegates to this future but will finish early (via a {@link
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
@IgnoreJRERequirement // Users will use this only if they're already using Duration. public static <V extends @Nullable Object> ListenableFuture<V> withTimeout( ListenableFuture<V> delegate, Duration time, ScheduledExecutorService scheduledExecutor) { return withTimeout(delegate, toNanosSaturated(time), TimeUnit.NANOSECONDS, scheduledExecutor); } /**
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for * example, if the deadline expires on a {@code Future} returned from {@link * Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So * beware: <i>Your {@code AsyncCallable} should not complete its {@code Future} until it is * safe for the next task to start.</i> * </ul> *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for * example, if the deadline expires on a {@code Future} returned from {@link * Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So * beware: <i>Your {@code AsyncCallable} should not complete its {@code Future} until it is * safe for the next task to start.</i> * </ul> *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0)