Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for AbstractFuture (0.05 sec)

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

    /**
     * Base class for tests for emulated {@link AbstractFuture} that allow subclasses to swap in a
     * different "source Future" for {@link AbstractFuture#setFuture} calls.
     */
    @GwtCompatible
    @NullUnmarked
    abstract class AbstractAbstractFutureTest extends TestCase {
      private TestedFuture<Integer> future;
      private AbstractFuture<Integer> delegate;
    
      abstract AbstractFuture<Integer> newDelegate();
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  3. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  4. 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 Sep 05 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/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
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  6. 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++) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java

     *   <li>Decrements a counter atomically
     * </ul>
     */
    @GwtCompatible
    @ReflectionSupport(value = ReflectionSupport.Level.FULL)
    abstract class AggregateFutureState<OutputT extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<OutputT> {
      /*
       * The following fields are package-private, even though we intend never to use them outside this
       * file. For discussion, see AbstractFutureState.
       */
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

            return object.toString();
          }
        };
      }
    
      public void testCancellationDuringReentrancy() throws Exception {
        TestLogHandler logHandler = new TestLogHandler();
        Logger.getLogger(AbstractFuture.class.getName()).addHandler(logHandler);
    
        List<Future<?>> results = new ArrayList<>();
        Runnable[] manualExecutorTask = new Runnable[1];
        Executor manualExecutor =
            new Executor() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 20:58:01 UTC 2025
    - 16.1K bytes
    - Viewed (0)
Back to top