Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 36 for AbstractFuture (0.05 sec)

  1. 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(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  2. android/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)
  3. android/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;
      }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  4. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 1.4K bytes
    - Viewed (0)
  5. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AggregateFutureState.java

    import java.util.Set;
    import org.jspecify.annotations.Nullable;
    
    /** Emulation of AggregateFutureState. */
    abstract class AggregateFutureState<OutputT extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<OutputT> {
      // Lazily initialized the first time we see an exception; not released until all the input futures
      // & this future completes. Released when the future releases the reference to the running state
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  6. guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFluentFutureCatchingSpecialization.java

     * FluentFuture.catching} family of methods. Those versions have slightly different signatures.
     */
    abstract class GwtFluentFutureCatchingSpecialization<V extends @Nullable Object>
        extends AbstractFuture<V> {
      /*
       * In the GWT versions of the methods (below), every exceptionType parameter is required to be
       * Class<Throwable>. To handle only certain kinds of exceptions under GWT, you'll need to write
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  7. 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
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  8. android/guava-testlib/src/com/google/common/testing/NullPointerTester.java

         * versions of Java, and apparently Unsafe can cause SIGSEGV instead of NPE—almost as if it's
         * not safe.
         */
        concat(
                stream(AbstractFuture.class.getDeclaredMethods()),
                stream(requireNonNull(AbstractFuture.class.getSuperclass()).getDeclaredMethods()))
            .filter(
                m ->
                    m.getName().equals("getDoneValue")
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 24.9K bytes
    - Viewed (0)
  9. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  10. 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 Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top