- Sort Score
- Result 10 results
- Languages All
Results 11 - 16 of 16 for TrustedFuture (0.13 sec)
-
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* interrupted and cancelled if it times out. */ @J2ktIncompatible @GwtIncompatible @ElementTypesAreNonnullByDefault final class TimeoutFuture<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V> { static <V extends @Nullable Object> ListenableFuture<V> create( ListenableFuture<V> delegate, long time, TimeUnit unit, ScheduledExecutorService scheduledExecutor) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 8.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
} else { collection = ImmutableList.copyOf(futures); } return (ListenableFuture<? extends T>[]) collection.toArray(new ListenableFuture<?>[0]); } // This can't be a TrustedFuture, because TrustedFuture has clever optimizations that // mean cancel won't be called if this Future is passed into setFuture, and then // cancelled. private static final class InCompletionOrderFuture<T extends @Nullable Object>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
@Override final void addInitialException(Set<Throwable> seen) { checkNotNull(seen); if (!isCancelled()) { /* * requireNonNull is safe because: * * - This is a TrustedFuture, so tryInternalFastPathGetFailure will in fact return the failure * cause if this Future has failed. * * - And this future *has* failed: This method is called only from handleException (through
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 16.2K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Futures.java
} else { collection = ImmutableList.copyOf(futures); } return (ListenableFuture<? extends T>[]) collection.toArray(new ListenableFuture<?>[0]); } // This can't be a TrustedFuture, because TrustedFuture has clever optimizations that // mean cancel won't be called if this Future is passed into setFuture, and then // cancelled. private static final class InCompletionOrderFuture<T extends @Nullable Object>
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 25 13:13:32 UTC 2024 - 64.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/FluentFuture.java
/** * A less abstract subclass of AbstractFuture. This can be used to optimize setFuture by ensuring * that {@link #get} calls exactly the implementation of {@link AbstractFuture#get}. */ abstract static class TrustedFuture<V extends @Nullable Object> extends FluentFuture<V> implements AbstractFuture.Trusted<V> { @CanIgnoreReturnValue @Override @ParametricNullness
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/util/concurrent/MoreExecutors.java
} } @J2ktIncompatible @GwtIncompatible // TODO private static final class NeverSuccessfulListenableFutureTask extends AbstractFuture.TrustedFuture<@Nullable Void> implements Runnable { private final Runnable delegate; public NeverSuccessfulListenableFutureTask(Runnable delegate) { this.delegate = checkNotNull(delegate); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 44.1K bytes - Viewed (0)