- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 15 for CANCELLED (0.25 seconds)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} case CANCELLED: case INTERRUPTED: throw cancellationExceptionWithCause("Task was cancelled.", exception); default: throw new IllegalStateException("Error, synchronizer in invalid state: " + state); } } /** Checks if the state is {@link #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}. */ boolean isDone() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
} case CANCELLED: case INTERRUPTED: throw cancellationExceptionWithCause("Task was cancelled.", exception); default: throw new IllegalStateException("Error, synchronizer in invalid state: " + state); } } /** Checks if the state is {@link #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}. */ boolean isDone() {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// before the cancelled future completes, it will synchronously complete both the newFuture // from the cancelled operation and its own. This can cause one runnable to queue two tasks, // breaking the invariant this method relies on to iteratively run the next task after the // previous one completes. if (get() == RunningState.CANCELLED) { delegate = null; sequencer = null;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
* <p>If the call {@code setFuture(delegate)} is accepted and this {@code Future} is later * cancelled, cancellation will be propagated to {@code delegate}. Additionally, any call to * {@code setFuture} after any cancellation will propagate cancellation to the supplied {@code * Future}. * * <p>Note that, even if the supplied future is cancelled and it causes this future to complete,Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* input future and that of the future returned by the chain function. That is, if the returned * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the * other two is cancelled, the returned {@code Future} will receive a callback in which it will * attempt to cancel itself. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 19.8K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between now * and then. This means that we're silently swallowing an exception -- maybe even an Error. But * this is no worse than what FutureTask does in that situation. Additionally, because the * Future was cancelled, its listeners have been run, so its consumers will not hang. *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
// stop it. blockingCallable.waitForStart(); // This time, cancel the future for the first task. The task remains running, only the future // is cancelled. future1.cancel(false); // Give the second task a chance to (incorrectly) start up while the first task is running. // (This is the assertion that fails.) assertThat(future2.isDone()).isFalse();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
} public void testToString_cancelled() throws Exception { assertThat(immediateCancelledFuture().toString()).matches("[^\\[]+\\[status=CANCELLED\\]"); } public void testToString_failed() { assertThat(immediateFailedFuture(new RuntimeException("foo")).toString())
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
// stop it. blockingCallable.waitForStart(); // This time, cancel the future for the first task. The task remains running, only the future // is cancelled. future1.cancel(false); // Give the second task a chance to (incorrectly) start up while the first task is running. // (This is the assertion that fails.) assertThat(future2.isDone()).isFalse();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
this.scheduledDelegate = scheduledDelegate; } @Override public boolean cancel(boolean mayInterruptIfRunning) { boolean cancelled = super.cancel(mayInterruptIfRunning); if (cancelled) { // Unless it is cancelled, the delegate may continue being scheduled scheduledDelegate.cancel(mayInterruptIfRunning); /*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)