Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for TimeoutFuture (0.05 sec)

  1. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

          // call to this method.
          TimeoutFuture<V> timeoutFuture = timeoutFutureRef;
          if (timeoutFuture == null) {
            return;
          }
          @RetainedLocalRef ListenableFuture<V> delegate = timeoutFuture.delegateRef;
          if (delegate == null) {
            return;
          }
    
          /*
           * If we're about to complete the TimeoutFuture, we want to release our reference to it.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java

      }
    
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       *
       * <p>{@code volatile} is required for j2objc transpiling:
       * https://developers.google.com/j2objc/guides/j2objc-memory-model#atomicity
       */
      private volatile @Nullable InterruptibleTask<?> task;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 5.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/CollectionFuture.java

        extends AggregateFuture<V, C> {
      /*
       * We access this field racily but safely. For discussion of a similar situation, see the comments
       * on the fields of TimeoutFuture. This field is slightly different from the fields discussed
       * there: cancel() never reads this field, only writes to it. That makes the race here completely
       * harmless, rather than just 99.99% harmless.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 3.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        return output;
      }
    
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @LazyInit @Nullable ListenableFuture<? extends I> inputFuture;
      @LazyInit @Nullable F function;
    
      AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) {
    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. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

        return output;
      }
    
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @LazyInit @Nullable ListenableFuture<? extends I> inputFuture;
      @LazyInit @Nullable F function;
    
      AbstractTransformFuture(ListenableFuture<? extends I> inputFuture, F function) {
    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/AggregateFuture.java

       */
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @LazyInit
      private @Nullable ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures;
    
      private final boolean allMustSucceed;
      private final boolean collectsValues;
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 16K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

          ListenableFuture<V> delegate,
          long time,
          TimeUnit unit,
          ScheduledExecutorService scheduledExecutor) {
        if (delegate.isDone()) {
          return delegate;
        }
        return TimeoutFuture.create(delegate, time, unit, scheduledExecutor);
      }
    
      /**
       * Returns a new {@code Future} whose result is asynchronously derived from the result of the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
Back to top