- Sort Score
- Num 10 results
- Language All
Results 11 - 17 of 17 for setFuture (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java
executor.execute(runnable); } }; Future<?> future = newFutureInstance(); future .getClass() .getMethod( "setFuture", future.getClass().getClassLoader().loadClass(ListenableFuture.class.getName())) .invoke(future, badFuture); CancellationException expected = assertThrows(CancellationException.class, () -> future.get());
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 6.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
() -> { if (taskFuture.isDone()) { // Since the value of oldFuture can only ever be immediateVoidFuture() or setFuture of a // future that eventually came from immediateVoidFuture(), this doesn't leak throwables // or completion values. newFuture.setFuture(oldFuture); } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* even with the above null checks.) */ timeoutFutureRef = null; if (delegate.isDone()) { timeoutFuture.setFuture(delegate); } else { try { @RetainedLocalRef ScheduledFuture<?> timer = timeoutFuture.timer; timeoutFuture.timer = null; // Don't include already elapsed delay in delegate.toString()Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
public void run() { // This prevents cancellation from propagating because we don't call setFuture(delegate) until // delegate is already done, so calling cancel() on this future won't affect it. @RetainedLocalRef ListenableFuture<V> localDelegate = delegate; if (localDelegate != null) { setFuture(localDelegate); } } @Override protected @Nullable String pendingToString() {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 64.3K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* either this Future was cancelled (which we ruled out with the isCancelled check above), * or it had already failed. (It couldn't have completed *successfully* or even had * setFuture called on it: Neither of those can happen until we've finished processing all * the completed inputs. And we're still processing at least one input, the one that * triggered handleException.) *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 16K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
* <li>{@link Cancellation} terminal state, {@code cancel} was called. * <li>{@link Failure} terminal state, {@code setException} was called. * <li>{@link DelegatingToFuture} intermediate state, {@code setFuture} was called. * <li>{@link #NULL} terminal state, {@code set(null)} was called. * <li>Any other non-null value, terminal state, {@code set} was called with a non-null * argument. * </ul> */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 33.2K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
* <li>{@link Cancellation} terminal state, {@code cancel} was called. * <li>{@link Failure} terminal state, {@code setException} was called. * <li>{@link DelegatingToFuture} intermediate state, {@code setFuture} was called. * <li>{@link #NULL} terminal state, {@code set(null)} was called. * <li>Any other non-null value, terminal state, {@code set} was called with a non-null * argument. * </ul> */
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 34.8K bytes - Click Count (0)