- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 3,298 for futures (0.14 sec)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
* * <p>Cancelling a delegate future propagates to input futures once all the delegates complete, * either from cancellation or because an input future has completed. If N futures are passed in, * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of * the input futures complete. If all the delegates are cancelled, all the input futures will be
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
* * <p>Cancelling a delegate future propagates to input futures once all the delegates complete, * either from cancellation or because an input future has completed. If N futures are passed in, * and M delegates are cancelled, the remaining M input futures will be cancelled once N - M of * the input futures complete. If all the delegates are cancelled, all the input futures will be
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 64.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
SettableFuture<Object> future1 = SettableFuture.create(); SettableFuture<Object> future2 = SettableFuture.create(); SettableFuture<Object> future3 = SettableFuture.create(); ListenableFuture<List<Object>> all = allAsList(future1, future2, future3); future1.setException(new MyException()); future2.setException(new MyException()); future3.setException(new MyException()); try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
SettableFuture<Object> future1 = SettableFuture.create(); SettableFuture<Object> future2 = SettableFuture.create(); SettableFuture<Object> future3 = SettableFuture.create(); ListenableFuture<List<Object>> all = allAsList(future1, future2, future3); future1.setException(new MyException()); future2.setException(new MyException()); future3.setException(new MyException()); try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 144.1K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AggregateFuture.java
// listener, and set this.futures to null. // This is not actually a problem, since the foreach only needs this.futures to be non-null // at the beginning of the loop. int i = 0; for (ListenableFuture<? extends InputT> future : futures) { int index = i++; future.addListener( () -> { try { if (future.isCancelled()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 15.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
// listener, and set this.futures to null. // This is not actually a problem, since the foreach only needs this.futures to be non-null // at the beginning of the loop. int i = 0; for (ListenableFuture<? extends InputT> future : futures) { int index = i++; future.addListener( () -> { try { if (future.isCancelled()) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 15.4K bytes - Viewed (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.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 3.8K bytes - Viewed (0) -
android/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.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 3.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} private final ClosingFuture<V1> future1; private final ClosingFuture<V2> future2; private final ClosingFuture<V3> future3; private Combiner3( ClosingFuture<V1> future1, ClosingFuture<V2> future2, ClosingFuture<V3> future3) { super(true, ImmutableList.of(future1, future2, future3)); this.future1 = future1; this.future2 = future2; this.future3 = future3; }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 98.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java
import static com.google.common.truth.Truth.assertThat; 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 com.google.common.annotations.GwtCompatible;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 2.2K bytes - Viewed (0)