- Sort Score
- Num 10 results
- Language All
Results 41 - 50 of 52 for SettableFuture (0.09 seconds)
-
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
import org.jspecify.annotations.Nullable; /** * An abstract implementation of {@link ListenableFuture}, intended for advanced users only. More * common ways to create a {@code ListenableFuture} include instantiating a {@link SettableFuture}, * submitting a task to a {@link ListeningExecutorService}, and deriving a {@code Future} from an * existing one, typically using methods like {@link Futures#transform(ListenableFuture,Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 14:39:00 GMT 2026 - 43.6K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java
assertThrows(CancellationException.class, () -> getDone(immediateCancelledFuture())); } public void testPending() throws ExecutionException { assertThrows(IllegalStateException.class, () -> getDone(SettableFuture.create())); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 2.3K bytes - Click Count (0) -
futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutureFailureAccess.java
* return value of this method as its cause * </ul> * * <p>This method is {@code protected} so that classes like {@code * com.google.common.util.concurrent.SettableFuture} do not expose it to their users as an * instance method. In the unlikely event that you need to call this method, call {@link * InternalFutures#tryInternalFastPathGetFailure(InternalFutureFailureAccess)}. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Jan 18 02:54:30 GMT 2025 - 2.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesGetDoneTest.java
assertThrows(CancellationException.class, () -> getDone(immediateCancelledFuture())); } public void testPending() throws ExecutionException { assertThrows(IllegalStateException.class, () -> getDone(SettableFuture.create())); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 2.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
assertThat(helperField.get(null).getClass().getSimpleName()).isEqualTo(expectedHelperClassName); } private static ClassLoader getClassLoader(Set<String> blocklist) { String concurrentPackage = SettableFuture.class.getPackage().getName(); ClassLoader classLoader = AggregateFutureStateFallbackAtomicHelperTest.class.getClassLoader(); // we delegate to the current classloader so both loaders agree on classes like TestCase
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.7K bytes - Click Count (0) -
android/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(LocalCache.<K, V>unset()); } /*
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 143.5K bytes - Click Count (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 =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 114.9K bytes - Click Count (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 =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Mar 18 18:06:14 GMT 2026 - 116.4K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
assertThat(helperField.get(null).getClass().getSimpleName()).isEqualTo(expectedHelperClassName); } private static ClassLoader getClassLoader(Set<String> blocklist) { String concurrentPackage = SettableFuture.class.getPackage().getName(); ClassLoader classLoader = AggregateFutureStateFallbackAtomicHelperTest.class.getClassLoader(); // we delegate to the current classloader so both loaders agree on classes like TestCase
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 6.7K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java
assertThat(helperMethod.invoke(null)).isEqualTo(expectedHelperClassName); } private static ClassLoader getClassLoader(Set<String> disallowedClassNames) { String concurrentPackage = SettableFuture.class.getPackage().getName(); ClassLoader classLoader = AbstractFutureFallbackAtomicHelperTest.class.getClassLoader(); // we delegate to the current classloader so both loaders agree on classes like TestCase
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.3K bytes - Click Count (0)