Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 10 for CANCELLED (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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-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)
  6. 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)
  7. 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)
  8. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       *       Futures#getUnchecked}.
       * </ul>
       *
       * @throws ExecutionException if the computation threw an exception
       * @throws CancellationException if the computation was cancelled
       */
      @CanIgnoreReturnValue
      @ParametricNullness
      public static <V extends @Nullable Object> V getUninterruptibly(Future<V> future)
          throws ExecutionException {
        boolean interrupted = false;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 23:24:32 GMT 2026
    - 22.5K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java

      private static final int MAX_BUSY_WAIT_SPINS = 1000;
    
      @Override
      public final void run() {
        /*
         * Set runner thread before checking isDone(). If we were to check isDone() first, the task
         * might be cancelled before we set the runner thread. That would make it impossible to
         * interrupt, yet it will still run, since interruptTask will leave the runner value null,
         * allowing the CAS below to succeed.
         */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jan 28 22:39:02 GMT 2026
    - 10K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

           * - And this future *has* failed: This method is called only from handleException (through
           *   getOrInitSeenExceptions). handleException tried to call setException and failed, so
           *   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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
Back to Top