- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 40 for AbstractFuture (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.3K bytes - Click Count (0) -
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 {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 2.1K bytes - Click Count (0) -
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 @GwtIncompatible @J2ktIncompatible public class AbstractFutureCancellationCauseTest extends TestCase {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
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 @GwtIncompatible @J2ktIncompatible public class AbstractFutureCancellationCauseTest extends TestCase {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 6.3K bytes - Click Count (0) -
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> { /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
android/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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 1.4K bytes - Click Count (0) -
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 intoCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 33.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
@CanIgnoreReturnValue boolean set(T t); @CanIgnoreReturnValue boolean setException(Throwable t); } private static class NewAbstractFutureFacade<T> extends AbstractFuture<T> implements Facade<T> { @CanIgnoreReturnValue @Override public boolean set(T t) { return super.set(t); } @CanIgnoreReturnValue @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0) -
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(Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 7.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
@CanIgnoreReturnValue boolean set(T t); @CanIgnoreReturnValue boolean setException(Throwable t); } private static class NewAbstractFutureFacade<T> extends AbstractFuture<T> implements Facade<T> { @CanIgnoreReturnValue @Override public boolean set(T t) { return super.set(t); } @CanIgnoreReturnValue @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 13.8K bytes - Click Count (0)