- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for SettableFuture (0.07 sec)
-
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* have completed - namely after oldFuture is done, and taskFuture has either completed or been * cancelled before the callable started execution. */ SettableFuture<@Nullable Void> newFuture = SettableFuture.create(); ListenableFuture<@Nullable Void> oldFuture = ref.getAndSet(newFuture); // Invoke our task once the previous future completes.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* have completed - namely after oldFuture is done, and taskFuture has either completed or been * cancelled before the callable started execution. */ SettableFuture<@Nullable Void> newFuture = SettableFuture.create(); ListenableFuture<@Nullable Void> oldFuture = ref.getAndSet(newFuture); // Invoke our task once the previous future completes.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
} public void testLongAsyncRefresh() throws Exception { FakeTicker ticker = new FakeTicker(); CountDownLatch reloadStarted = new CountDownLatch(1); SettableFuture<Thread> threadAboutToBlockForRefresh = SettableFuture.create(); ListeningExecutorService refreshExecutor = listeningDecorator(newSingleThreadExecutor()); try { CacheBuilder<Object, Object> builder =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 110.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
} public void testLongAsyncRefresh() throws Exception { FakeTicker ticker = new FakeTicker(); CountDownLatch reloadStarted = new CountDownLatch(1); SettableFuture<Thread> threadAboutToBlockForRefresh = SettableFuture.create(); ListeningExecutorService refreshExecutor = listeningDecorator(newSingleThreadExecutor()); try { CacheBuilder<Object, Object> builder =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 112.3K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
* forwards to that future and adds the desired methods. * * @since 23.0 */ @DoNotMock("Use FluentFuture.from(Futures.immediate*Future) or SettableFuture") @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault public abstract class FluentFuture<V extends @Nullable Object> extends GwtFluentFutureCatchingSpecialization<V> { /**
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 19.6K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
volatile ValueReference<K, V> oldValue; // TODO(fry): rename get, then extend AbstractFuture instead of containing SettableFuture final SettableFuture<V> futureValue = SettableFuture.create(); final Stopwatch stopwatch = Stopwatch.createUnstarted(); public LoadingValueReference() { this(null); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 149.2K bytes - Viewed (0)