- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for SettableFuture (0.19 sec)
-
guava/src/com/google/common/util/concurrent/SettableFuture.java
*/ @GwtCompatible @ElementTypesAreNonnullByDefault 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
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 01 17:18:04 UTC 2021 - 2.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SettableFuture.java
*/ @GwtCompatible @ElementTypesAreNonnullByDefault 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
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 01 17:18:04 UTC 2021 - 2.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
WeakReference<Object> ref = new WeakReference<>(toBeGCed); final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create(); ListenableFuture<?> ignored = serializer.submitAsync( new AsyncCallable<@Nullable Void>() { @Override public ListenableFuture<@Nullable Void> call() { return settableFuture; } }, directExecutor());
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/SettableFutureTest.java
SettableFuture<String> future = SettableFuture.create(); SettableFuture<String> nested = SettableFuture.create(); assertTrue(future.setFuture(nested)); // Later attempts to set the future should return false. assertFalse(future.set("x")); assertFalse(future.setException(new Exception("bar"))); assertFalse(future.setFuture(SettableFuture.<String>create()));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java
assertEquals("foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class)); } public void testGetCheckedUntimed_interrupted() { SettableFuture<String> future = SettableFuture.create(); Thread.currentThread().interrupt(); try { getChecked(future, TwoArgConstructorException.class); fail(); } catch (TwoArgConstructorException expected) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.3K bytes - Viewed (0) -
guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
unused = null; // Hint to the JIT that unused is unreachable GcFinalization.await(latch); assertEquals(0, latch.getCount()); } public void testAwaitDone_future() { final SettableFuture<@Nullable Void> future = SettableFuture.create(); Object unused = new Object() { @SuppressWarnings({"removal", "Finalize"}) // b/260137033 @Override protected void finalize() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 7.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java
SettableFuture<String> future = SettableFuture.create(); SettableFuture<String> nested = SettableFuture.create(); assertTrue(future.setFuture(nested)); // Later attempts to set the future should return false. assertFalse(future.set("x")); assertFalse(future.setException(new Exception("bar"))); assertFalse(future.setFuture(SettableFuture.<String>create()));
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 7.3K bytes - Viewed (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
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-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
WeakReference<Object> ref = new WeakReference<>(toBeGCed); final SettableFuture<@Nullable Void> settableFuture = SettableFuture.create(); ListenableFuture<?> ignored = serializer.submitAsync( new AsyncCallable<@Nullable Void>() { @Override public ListenableFuture<@Nullable Void> call() { return settableFuture; } }, directExecutor());
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 16.7K bytes - Viewed (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");
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 15:41:36 UTC 2024 - 6.6K bytes - Viewed (0)