Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for AbstractFuture (0.06 sec)

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

    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link AbstractFuture} that use a non-{@link TrustedFuture} for {@link
     * AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    @NullUnmarked
    public class UntrustedInputFutureTest extends AbstractAbstractFutureTest {
      @Override
      AbstractFuture<Integer> newDelegate() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 1.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/TrustedInputFutureTest.java

    import com.google.common.util.concurrent.AbstractFuture.TrustedFuture;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link AbstractFuture} that use a {@link TrustedFuture} for {@link
     * AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    @NullUnmarked
    public class TrustedInputFutureTest extends AbstractAbstractFutureTest {
      @Override
      AbstractFuture<Integer> newDelegate() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Jan 18 02:54:30 UTC 2025
    - 1.2K bytes
    - Viewed (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
    public class AbstractFutureCancellationCauseTest extends TestCase {
    
      private ClassLoader oldClassLoader;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  4. 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> {
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  5. 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> {
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  6. android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java

    import java.util.HashSet;
    import java.util.Set;
    import java.util.concurrent.Executor;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Measures the size of AbstractFuture implementations. */
    @NullUnmarked
    public class AbstractFutureFootprintBenchmark {
    
      enum State {
        NOT_DONE,
        FINISHED,
        CANCELLED,
        FAILED
      }
    
      @Param State state;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top