Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 36 for AbstractFuture (0.22 sec)

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

    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests our AtomicHelper fallback strategies in AbstractFuture.
     *
     * <p>On different platforms AbstractFuture uses different strategies for its core synchronization
     * primitives. The strategies are all implemented as subtypes of AtomicHelper and the strategy is
     * selected in the static initializer of AbstractFuture. This is convenient and performant but
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 7.3K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      }
    
      /** Constructor for use by {@link AbstractFuture}. */
      AbstractFutureState() {}
    
      /*
       * We put various static objects here rather than in AbstractFuture so that they're initialized in
       * time for AbstractFutureState to potentially use them during class initialization.
       * (AbstractFutureState class initialization can log, and that logging could in theory call into
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  3. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/Platform.java

          throw (Error) t;
        }
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future)
          throws InterruptedException, ExecutionException {
        return future.getFromAlreadyDoneTrustedFuture();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 27 16:15:49 UTC 2025
    - 2K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/Platform.java

          throw (Error) t;
        }
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future)
          throws InterruptedException, ExecutionException {
        return future.blockingGet();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/Platform.java

          throw (Error) t;
        }
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future)
          throws InterruptedException, ExecutionException {
        return future.blockingGet();
      }
    
      static <V extends @Nullable Object> V get(AbstractFuture<V> future, long timeout, TimeUnit unit)
          throws InterruptedException, ExecutionException, TimeoutException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      }
    
      /** Constructor for use by {@link AbstractFuture}. */
      AbstractFutureState() {}
    
      /*
       * We put various static objects here rather than in AbstractFuture so that they're initialized in
       * time for AbstractFutureState to potentially use them during class initialization.
       * (AbstractFutureState class initialization can log, and that logging could in theory call into
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         *
         * - Any kind of Error from a listener. Even if we could distinguish that case (by exposing some
         * extra state from AbstractFuture), our options are limited: A call to setException() would be
         * a no-op. We could log, but if that's what we really want, we should modify
         * AbstractFuture.executeListener to do so, since that method would have the ability to continue
         * to execute other listeners.
         *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

    import static java.util.concurrent.TimeUnit.NANOSECONDS;
    
    import com.google.common.annotations.GwtIncompatible;
    import com.google.common.collect.ImmutableList;
    import com.google.common.util.concurrent.AbstractFuture;
    import com.google.common.util.concurrent.AbstractListeningExecutorService;
    import com.google.common.util.concurrent.ListenableScheduledFuture;
    import com.google.common.util.concurrent.ListeningScheduledExecutorService;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 6.6K bytes
    - Viewed (0)
  9. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
     *       create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer
     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
     * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ListenableFuture.java

     *   <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method,
     *       create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer
     *       {@link AbstractFuture}.)
     * </ul>
     *
     * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
     * SettableFuture} or one of the methods in the {@link Futures#immediateFuture Futures.immediate*}
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 8K bytes
    - Viewed (0)
Back to top