- Sort Score
- Result 10 results
- Languages All
Results 31 - 36 of 36 for AbstractFuture (0.04 sec)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
InCompletionOrderState<T> state = new InCompletionOrderState<>(copy); ImmutableList.Builder<AbstractFuture<T>> delegatesBuilder = ImmutableList.builderWithExpectedSize(copy.length); for (int i = 0; i < copy.length; i++) { delegatesBuilder.add(new InCompletionOrderFuture<T>(state)); } ImmutableList<AbstractFuture<T>> delegates = delegatesBuilder.build(); for (int i = 0; i < copy.length; i++) {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/NullPointerTester.java
* versions of Java, and apparently Unsafe can cause SIGSEGV instead of NPE—almost as if it's * not safe. */ concat( stream(AbstractFuture.class.getDeclaredMethods()), stream(requireNonNull(AbstractFuture.class.getSuperclass()).getDeclaredMethods())) .filter( m -> m.getName().equals("getDoneValue")
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Jul 14 14:44:08 UTC 2025 - 25.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java
if (Modifier.isPublic(method.getModifiers()) && method.getName().startsWith("test") /* * When we block access to AtomicReferenceFieldUpdater, we can't even reflect on * AbstractFuture, since it declares methods that use that type in their signatures. */ && !method.getName().equals("testFutures_nullChecks")) { suite.addTest( TestSuite.createTest(
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 18:46:00 UTC 2025 - 6.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
return object.toString(); } }; } public void testCancellationDuringReentrancy() throws Exception { TestLogHandler logHandler = new TestLogHandler(); Logger.getLogger(AbstractFuture.class.getName()).addHandler(logHandler); List<Future<?>> results = new ArrayList<>(); Runnable[] manualExecutorTask = new Runnable[1]; Executor manualExecutor = new Executor() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
return scheduledDelegate.compareTo(other); } } @GwtIncompatible // TODO private static final class NeverSuccessfulListenableFutureTask extends AbstractFuture.TrustedFuture<@Nullable Void> implements Runnable { private final Runnable delegate; NeverSuccessfulListenableFutureTask(Runnable delegate) { this.delegate = checkNotNull(delegate); }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Wed Oct 08 18:55:33 UTC 2025 - 45.2K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
} } } static class LoadingValueReference<K, V> implements ValueReference<K, V> { 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() {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 19:35:11 UTC 2025 - 148.9K bytes - Viewed (0)