- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 20 for cancellation (0.18 seconds)
-
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* * <p>This class has limited support for cancellation and other "early completions": * * <ul> * <li>While calls to {@code submit} and {@code submitAsync} return a {@code Future} that can be * cancelled, cancellation never propagates to a task that has started to run -- neither to * the callable itself nor to any {@code Future} returned by an {@code AsyncCallable}.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* * <p>This class has limited support for cancellation and other "early completions": * * <ul> * <li>While calls to {@code submit} and {@code submitAsync} return a {@code Future} that can be * cancelled, cancellation never propagates to a task that has started to run -- neither to * the callable itself nor to any {@code Future} returned by an {@code AsyncCallable}.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* All elements of `futures` are completed, or this future has already completed and read * `futures` into a local variable (in preparation for propagating cancellation to them). In * either case, no one needs to read `futures` for cancellation purposes later. (And * cancellation purposes are the main reason to access `futures`, as discussed in its docs.) */ this.futures = null; } enum ReleaseResourcesReason {Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 16K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* * <p>When chaining together a graph of asynchronous operations, you will often find it easier to * use a framework. Frameworks automate the process, often adding features like monitoring, * debugging, and cancellation. Examples of frameworks include: * * <ul> * <li><a href="https://dagger.dev/producers.html">Dagger Producers</a> * </ul> *
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 19.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
} inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused = setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between nowCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
* Implementations must support such concurrent calls. * * Note that cancellation is best-effort and that a call may proceed normally after it has been * canceled. For example, happy-path events like [requestHeadersStart] and [requestHeadersEnd] may * occur after a call is canceled. Typically cancellation takes effect when an expensive I/O * operation is required. *
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:03:04 GMT 2025 - 24.9K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java
} inputFuture = null; if (localInputFuture.isCancelled()) { @SuppressWarnings("unchecked") boolean unused = setFuture((ListenableFuture<O>) localInputFuture); // Respects cancellation cause setting return; } /* * Any of the setException() calls below can fail if the output Future is cancelled between nowCreated: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0) -
cmd/erasure-metadata-utils.go
errorCounts := make(map[error]int) for _, err := range errs { if IsErrIgnored(err, ignoredErrs...) { continue } // Errors due to context cancellation may be wrapped - group them by context.Canceled. if errors.Is(err, context.Canceled) { errorCounts[context.Canceled]++ continue } errorCounts[err]++ } maxCnt := 0
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.7K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* cycle_suppress_list.txt. */ private final AbstractService service; /** * This lock is used to ensure safe and correct cancellation, it ensures that a new task is * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to * ensure that it is assigned atomically with being scheduled. */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.7K bytes - Click Count (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* cycle_suppress_list.txt. */ private final AbstractService service; /** * This lock is used to ensure safe and correct cancellation, it ensures that a new task is * not scheduled while a cancel is ongoing. Also it protects the currentFuture variable to * ensure that it is assigned atomically with being scheduled. */Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sat Aug 09 01:14:59 GMT 2025 - 27.8K bytes - Click Count (0)