- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 36 for AbstractFuture (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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); } @OverrideRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 15.8K bytes - Viewed (0) -
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) -
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 @ParametricNullnessRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.7K bytes - Viewed (0) -
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)