- Sort Score
- Num 10 results
- Language All
Results 31 - 40 of 52 for AbstractFuture (0.21 seconds)
-
android/guava-tests/benchmark/com/google/common/util/concurrent/AbstractFutureFootprintBenchmark.java
import java.util.HashSet; import java.util.Set; import java.util.concurrent.Executor; import org.jspecify.annotations.NullUnmarked; /** Measures the size of AbstractFuture implementations. */ @NullUnmarked public class AbstractFutureFootprintBenchmark { enum State { NOT_DONE, FINISHED, CANCELLED, FAILED } @Param State state;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue May 13 18:46:00 GMT 2025 - 3K bytes - Click Count (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
import static java.util.concurrent.TimeUnit.NANOSECONDS; import com.google.common.annotations.GwtIncompatible; import com.google.common.collect.ImmutableList; import com.google.common.util.concurrent.AbstractFuture; import com.google.common.util.concurrent.AbstractListeningExecutorService; import com.google.common.util.concurrent.ListenableScheduledFuture; import com.google.common.util.concurrent.ListeningScheduledExecutorService;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (0) -
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; }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.3K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
import static java.util.concurrent.TimeUnit.NANOSECONDS; import com.google.common.annotations.GwtIncompatible; import com.google.common.collect.ImmutableList; import com.google.common.util.concurrent.AbstractFuture; import com.google.common.util.concurrent.AbstractListeningExecutorService; import com.google.common.util.concurrent.ListenableScheduledFuture; import com.google.common.util.concurrent.ListeningScheduledExecutorService;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jul 17 15:26:41 GMT 2025 - 6.6K bytes - Click Count (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); } @OverrideCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jul 16 17:42:14 GMT 2025 - 15.8K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
if (Modifier.isPublic(method.getModifiers()) && method.getName().startsWith("test") /* * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on * AbstractFuture, since it declares methods that use that type in their signatures. */ && !method.getName().equals("testFutures_nullChecks")) { suite.addTest( TestSuite.createTest(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.7K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
if (Modifier.isPublic(method.getModifiers()) && method.getName().startsWith("test") /* * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on * AbstractFuture, since it declares methods that use that type in their signatures. */ && !method.getName().equals("testFutures_nullChecks")) { suite.addTest( TestSuite.createTest(
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.7K bytes - Click Count (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 @ParametricNullnessCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 19.8K bytes - Click Count (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++) {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
BarChild barChild = new BarChild(); AsyncFunction<Foo, BarChild> function = new AsyncFunction<Foo, BarChild>() { @Override public AbstractFuture<BarChild> apply(Foo unused) { AbstractFuture<BarChild> future = new AbstractFuture<BarChild>() {}; future.set(barChild); return future; } };
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0)