- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 201 for Future (0.08 sec)
-
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: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 08 19:36:35 UTC 2024 - 98.5K 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: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
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: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
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; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K 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++; if (future.isDone()) { processAllMustSucceedDoneFuture(index, future); } else { future.addListener(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* completing the returned {@code Future}.) * * <p>The returned {@code Future} attempts to keep its cancellation state in sync with that of the * input future and that of the future returned by the chain function. That is, if the returned * {@code Future} is cancelled, it will attempt to cancel the other two, and if either of the * other two is cancelled, the returned {@code Future} will receive a callback in which it will
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (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; } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
InterruptibleFuture future = new InterruptibleFuture(); assertTrue(future.cancel(false)); assertTrue(future.isCancelled()); assertTrue(future.isDone()); assertFalse(future.wasInterrupted()); assertFalse(future.interruptTaskWasCalled); CancellationException e = assertThrows(CancellationException.class, () -> future.get()); assertThat(e).hasCauseThat().isNull(); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 47.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} /** * Invokes {@code future.}{@link Future#get() get()} uninterruptibly. * * <p>Similar methods: * * <ul> * <li>To retrieve a result from a {@code Future} that is already done, use {@link * Futures#getDone Futures.getDone}. * <li>To treat {@link InterruptedException} uniformly with other exceptions, use {@link * Futures#getChecked(Future, Class) Futures.getChecked}.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 20.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java
assertThat(future.isDone()).isFalse(); assertThat(future.set(1)).isTrue(); assertSuccessful(future, 1); } public void testSetFutureNull() throws Exception { assertThrows(NullPointerException.class, () -> future.setFuture(null)); assertThat(future.isDone()).isFalse(); assertThat(future.set(1)).isTrue();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 15.5K bytes - Viewed (0)