Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 40 for AbstractFuture (0.06 seconds)

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

  1. android/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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.3K bytes
    - Click Count (0)
  2. 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 {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class AbstractFutureCancellationCauseTest extends TestCase {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Executor;
    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class AbstractFutureCancellationCauseTest extends TestCase {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

     * error. If your needs are more complex than {@code SettableFuture} supports, use {@link
     * AbstractFuture}, which offers an extensible version of the API.
     *
     * @author Sven Mawson
     * @since 9.0 (in 1.0 as {@code ValueFuture})
     */
    @GwtCompatible
    public final class SettableFuture<V extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<V> {
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java

     */
    @GwtCompatible
    @J2ktIncompatible // Super-sourced
    abstract class GwtFluentFutureCatchingSpecialization<V extends @Nullable Object>
        extends AbstractFuture<V> {
      /*
       * This server copy of the class is empty. The corresponding GWT copy contains alternative
       * versions of catching() and catchingAsync() with slightly different signatures from the ones
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 1.4K bytes
    - Click Count (0)
  7. 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
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        @CanIgnoreReturnValue
        boolean set(T t);
    
        @CanIgnoreReturnValue
        boolean setException(Throwable t);
      }
    
      private static class NewAbstractFutureFacade<T> extends AbstractFuture<T> implements Facade<T> {
        @CanIgnoreReturnValue
        @Override
        public boolean set(T t) {
          return super.set(t);
        }
    
        @CanIgnoreReturnValue
        @Override
    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)
  9. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       *
       * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link
       * MoreExecutors#listeningDecorator( java.util.concurrent.ExecutorService)}, {@link
       * ListenableFutureTask}, {@link AbstractFuture}, and other utilities over creating plain {@code
       * Future} instances to be upgraded to {@code ListenableFuture} after the fact.
       */
      public static <V extends @Nullable Object> ListenableFuture<V> listenInPoolThread(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 7.5K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        @CanIgnoreReturnValue
        boolean set(T t);
    
        @CanIgnoreReturnValue
        boolean setException(Throwable t);
      }
    
      private static class NewAbstractFutureFacade<T> extends AbstractFuture<T> implements Facade<T> {
        @CanIgnoreReturnValue
        @Override
        public boolean set(T t) {
          return super.set(t);
        }
    
        @CanIgnoreReturnValue
        @Override
    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)
Back to Top