Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 52 for AbstractFuture (0.08 seconds)

  1. 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;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 3K bytes
    - Click Count (0)
  2. 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;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

     * SettableFuture}).
     *
     * <p>Useful for testing the behavior of Future utilities against odd futures.
     *
     * @author Anthony Zana
     */
    @GwtCompatible
    @NullUnmarked
    final class UncheckedThrowingFuture<V> extends AbstractFuture<V> {
    
      public static <V> ListenableFuture<V> throwingError(Error error) {
        UncheckedThrowingFuture<V> future = new UncheckedThrowingFuture<V>();
        future.complete(checkNotNull(error));
        return future;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 3.3K bytes
    - Click Count (0)
  4. 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;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 6.6K bytes
    - Click Count (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java

              }
            };
          }
        },
        ABSTRACT_FUTURE {
          @Override
          ExecutionListWrapper newExecutionList() {
            return new ExecutionListWrapper() {
              final AbstractFuture<?> future = new AbstractFuture<Object>() {};
    
              @Override
              public void add(Runnable runnable, Executor executor) {
                future.addListener(runnable, executor);
              }
    
              @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

          if (Modifier.isPublic(method.getModifiers())
              && method.getName().startsWith("test")
              /*
               * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on
               * AbstractFuture, since it declares methods that use that type in their signatures.
               */
              && !method.getName().equals("testFutures_nullChecks")) {
            suite.addTest(
                TestSuite.createTest(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

          if (Modifier.isPublic(method.getModifiers())
              && method.getName().startsWith("test")
              /*
               * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on
               * AbstractFuture, since it declares methods that use that type in their signatures.
               */
              && !method.getName().equals("testFutures_nullChecks")) {
            suite.addTest(
                TestSuite.createTest(
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/FluentFuture.java

      /**
       * 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>
          implements AbstractFuture.Trusted<V> {
        @CanIgnoreReturnValue
        @Override
        @ParametricNullness
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

        InCompletionOrderState<T> state = new InCompletionOrderState<>(copy);
        ImmutableList.Builder<AbstractFuture<T>> delegatesBuilder =
            ImmutableList.builderWithExpectedSize(copy.length);
        for (int i = 0; i < copy.length; i++) {
          delegatesBuilder.add(new InCompletionOrderFuture<T>(state));
        }
    
        ImmutableList<AbstractFuture<T>> delegates = delegatesBuilder.build();
        for (int i = 0; i < copy.length; i++) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        BarChild barChild = new BarChild();
        AsyncFunction<Foo, BarChild> function =
            new AsyncFunction<Foo, BarChild>() {
              @Override
              public AbstractFuture<BarChild> apply(Foo unused) {
                AbstractFuture<BarChild> future = new AbstractFuture<BarChild>() {};
                future.set(barChild);
                return future;
              }
            };
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top