- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 40 for SettableFuture (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
*/ @GwtCompatible public final class SettableFuture<V extends @Nullable Object> extends AbstractFuture.TrustedFuture<V> { /** * Creates a new {@code SettableFuture} that can be completed or cancelled by a later method call. */ public static <V extends @Nullable Object> SettableFuture<V> create() { return new SettableFuture<>(); } @CanIgnoreReturnValue @Override
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} }; final SettableFuture<String> delayedSuccess = SettableFuture.create(); final SettableFuture<String> delayedFailed = SettableFuture.create(); final SettableFuture<String> delayedCancelled = SettableFuture.create(); final SettableFuture<String> delegateForDelayedRuntimeException = SettableFuture.create(); final ListenableFuture<String> delayedRuntimeException =Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
} }; final SettableFuture<String> delayedSuccess = SettableFuture.create(); final SettableFuture<String> delayedFailed = SettableFuture.create(); final SettableFuture<String> delayedCancelled = SettableFuture.create(); final SettableFuture<String> delegateForDelayedRuntimeException = SettableFuture.create(); final ListenableFuture<String> delayedRuntimeException =Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 134K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<Object> async = SettableFuture.create(); SettableFuture<Object> inner = SettableFuture.create(); async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, inner::get); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<Object> async = SettableFuture.create(); SettableFuture<Object> inner = SettableFuture.create(); async.setFuture(inner); async.cancel(false); assertTrue(inner.isCancelled()); assertFalse(inner.wasInterrupted()); assertThrows(CancellationException.class, inner::get); } public void testCancel_beforeSet() throws Exception { SettableFuture<Object> async = SettableFuture.create();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
} settableFuture.set(null); getDone(allAsList(results)); } public void testAvoidsStackOverflow_manyCancelled() throws Exception { SettableFuture<@Nullable Void> settableFuture = SettableFuture.create(); ListenableFuture<@Nullable Void> unused = serializer.submitAsync(() -> settableFuture, directExecutor()); for (int i = 0; i < 50_000; i++) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 13.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
SettableFuture<String> future = SettableFuture.create(); FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false); runNInterruptsTest(times, future, interruptReporter); } private static void runTimedInterruptsTest(int times) throws InterruptedException, ExecutionException, TimeoutException { SettableFuture<String> future = SettableFuture.create();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java
public void testSameThreadSuccess() { SettableFuture<String> f = SettableFuture.create(); MockCallback callback = new MockCallback("foo"); addCallback(f, callback, directExecutor()); f.set("foo"); } public void testExecutorSuccess() { CountingSameThreadExecutor ex = new CountingSameThreadExecutor(); SettableFuture<String> f = SettableFuture.create(); MockCallback callback = new MockCallback("foo");
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 15:59:55 GMT 2026 - 6.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// together. Now it should only be limited by available memory (and time) public void testSetFuture_stackOverflow() { SettableFuture<String> orig = SettableFuture.create(); SettableFuture<String> prev = orig; for (int i = 0; i < 100000; i++) { SettableFuture<String> curr = SettableFuture.create(); prev.setFuture(curr); prev = curr; } // prev represents the 'innermost' future
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 45.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
SettableFuture<String> future = SettableFuture.create(); FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false); runNInterruptsTest(times, future, interruptReporter); } private static void runTimedInterruptsTest(int times) throws InterruptedException, ExecutionException, TimeoutException { SettableFuture<String> future = SettableFuture.create();
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 8.9K bytes - Click Count (0)