- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 354 for Futures (0.04 seconds)
-
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * {@snippet : * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name); * future.addListener(new Runnable() { * public void run() {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Mar 17 20:26:29 GMT 2025 - 8K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
import com.google.common.annotations.J2ktIncompatible; /** * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function, * java.util.concurrent.Executor) Futures.catching} family of methods. Those versions have slightly * different signatures. */ @GwtCompatibleCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 1.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FuturesGetChecked.java
static <V extends @Nullable Object, X extends Exception> V getChecked( Future<V> future, Class<X> exceptionClass) throws X { return getChecked(bestGetCheckedTypeValidator(), future, exceptionClass); } /** Implementation of {@link Futures#getChecked(Future, Class)}. */ @CanIgnoreReturnValue @VisibleForTesting @ParametricNullness static <V extends @Nullable Object, X extends Exception> V getChecked(
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 10.2K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/CollectionFuture.java
CollectionFuture( ImmutableCollection<? extends ListenableFuture<? extends V>> futures, boolean allMustSucceed) { super(futures, allMustSucceed, true); List<@Nullable Present<V>> values = futures.isEmpty() ? Collections.<@Nullable Present<V>>emptyList() : Lists.<@Nullable Present<V>>newArrayListWithCapacity(futures.size()); // Populate the results list with null initially.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 3.9K bytes - Click Count (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/FuturesGetCheckedBenchmark.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue May 13 17:27:14 GMT 2025 - 6.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
List<Future<String>> futures = testExecutor.invokeAll(tasks); mock.assertLastMethodCalled("invokeAll"); checkResults(futures); } { MockExecutor mock = new MockExecutor(); TimeUnit unit = SECONDS; long timeout = 5; TestExecutor testExecutor = new TestExecutor(mock); List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 9.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java
import static com.google.common.util.concurrent.Futures.getDone; import static com.google.common.util.concurrent.Futures.immediateCancelledFuture; import static com.google.common.util.concurrent.Futures.immediateFailedFuture; import static com.google.common.util.concurrent.Futures.immediateFuture; import static com.google.common.util.concurrent.Futures.immediateVoidFuture;
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 2.3K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/GwtFuturesCatchingSpecialization.java
import java.util.concurrent.Executor; import org.jspecify.annotations.Nullable; /** * Hidden superclass of {@link Futures} that provides us a place to declare special GWT versions of * the {@link Futures#catching(ListenableFuture, Class, com.google.common.base.Function) * Futures.catching} family of methods. Those versions have slightly different signatures. */ abstract class GwtFuturesCatchingSpecialization { /*Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
private final ListenableFuture<@Nullable Void> future; private boolean called = false; private TestCallable(ListenableFuture<@Nullable Void> future) { this.future = future; } @Override public ListenableFuture<@Nullable Void> call() throws Exception { called = true; return future; } }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 16.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/collect/ConcurrentHashMultisetBasherTest.java
try { List<Future<int[]>> futures = newArrayListWithExpectedSize(nTasks); for (int i = 0; i < nTasks; i++) { futures.add(pool.submit(new MutateTask(multiset, keys))); } int[] deltas = new int[3]; for (Future<int[]> future : futures) { int[] taskDeltas = future.get(); for (int i = 0; i < deltas.length; i++) {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Dec 08 22:42:14 GMT 2025 - 5.7K bytes - Click Count (0)