- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for AbstractFuture (0.05 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)