Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for setFuture (0.25 sec)

  1. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
            if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) {
              // If setFuture fails or set on the future fails then it must be because that future was
              // cancelled
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertCancelled(future, true);
      }
    
      public void testSetFuturePending() throws Exception {
        assertThat(future.setFuture(delegate)).isTrue();
        assertSetAsynchronously(future);
      }
    
      public void testSetFutureThenCancel() throws Exception {
        assertThat(future.setFuture(delegate)).isTrue();
        assertThat(future.cancel(false /* mayInterruptIfRunning */)).isTrue();
        assertCancelled(future, false);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

            // cancellation can interleave in 3 ways
            // 1. prior to setFuture
            // 2. after setFuture before set() on the future assigned
            // 3. after setFuture and set() are called but before the listener completes.
            if (!setFutureSetSuccess.get() || !setFutureCompletionSuccess.get()) {
              // If setFuture fails or set on the future fails then it must be because that future was
              // cancelled
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          return;
        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  5. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          return;
        }
        inputFuture = null;
    
        if (localInputFuture.isCancelled()) {
          @SuppressWarnings("unchecked")
          boolean unused =
              setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting
          return;
        }
    
        /*
         * Any of the setException() calls below can fail if the output Future is cancelled between now
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

            () -> {
              if (taskFuture.isDone()) {
                // Since the value of oldFuture can only ever be immediateFuture(null) or setFuture of
                // a future that eventually came from immediateFuture(null), this doesn't leak
                // throwables or completion values.
                newFuture.setFuture(oldFuture);
              } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  7. 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.)
           *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  8. 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>
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  9. 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>
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

    @GwtCompatible
    public abstract class FluentFuture<V extends @Nullable Object>
        extends GwtFluentFutureCatchingSpecialization<V> {
    
      /**
       * A less abstract subclass of AbstractFuture. This can be used to optimize setFuture by ensuring
       * that {@link #get} calls exactly the implementation of {@link AbstractFuture#get}.
       */
      abstract static class TrustedFuture<V extends @Nullable Object> extends FluentFuture<V>
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
Back to top