- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 69 for isCancelled (0.05 sec)
-
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
super.afterDone(); @RetainedLocalRef ImmutableCollection<? extends Future<?>> localFutures = futures; releaseResources(OUTPUT_FUTURE_DONE); // nulls out `futures` if (isCancelled() & localFutures != null) { boolean wasInterrupted = wasInterrupted(); for (Future<?> future : localFutures) { future.cancel(wasInterrupted); } } /*
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 16K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java
future.set(null); } }; unused = null; // Hint to the JIT that unused is unreachable GcFinalization.awaitDone(future); assertTrue(future.isDone()); assertFalse(future.isCancelled()); } public void testAwaitDone_future_cancel() { SettableFuture<@Nullable Void> future = SettableFuture.create(); Object unused = new Object() {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Dec 08 17:02:07 UTC 2025 - 7.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
@RetainedLocalRef ListenableFuture<? extends I> localInputFuture = inputFuture; @RetainedLocalRef F localFunction = function; if (isCancelled() | localInputFuture == null | localFunction == null) { return; } inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused =
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 20 18:03:37 UTC 2025 - 10.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
@RetainedLocalRef ListenableFuture<? extends I> localInputFuture = inputFuture; @RetainedLocalRef F localFunction = function; if (isCancelled() | localInputFuture == null | localFunction == null) { return; } inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused =
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Feb 20 18:03:37 UTC 2025 - 10.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
return super.get(timeout, unit); } @Override public final boolean isDone() { return super.isDone(); } @Override public final boolean isCancelled() { return super.isCancelled(); } @Override public final void addListener(Runnable listener, Executor executor) { super.addListener(listener, executor); } @CanIgnoreReturnValue
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
results.add(serializer.submit(Callables.returning(null), directExecutor())); } manualExecutorTask[0].run(); for (Future<?> result : results) { if (!result.isCancelled()) { result.get(10, SECONDS); } // TODO(cpovirk): Verify that the cancelled futures are exactly ones that we expect. } assertThat(logHandler.getStoredLogRecords()).isEmpty(); }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 16.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
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/src/com/google/common/util/concurrent/ExecutionSequencer.java
// future that eventually came from immediateVoidFuture(), this doesn't leak throwables // or completion values. newFuture.setFuture(oldFuture); } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) { // If this CAS succeeds, we know that the provided callable will never be invoked, // so when oldFuture completes it is safe to allow the next submitted task to
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// future that eventually came from immediateVoidFuture(), this doesn't leak throwables // or completion values. newFuture.setFuture(oldFuture); } else if (outputFuture.isCancelled() && taskExecutor.trySetCancelled()) { // If this CAS succeeds, we know that the provided callable will never be invoked, // so when oldFuture completes it is safe to allow the next submitted task to
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Sep 23 01:35:55 UTC 2025 - 22.1K bytes - Viewed (0)