Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for CANCELLED (0.25 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top