Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 15 for Cancellation (0.06 seconds)

  1. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

        // unmeasurable (comparing done AbstractFutures with immediateFuture)
        if (obj instanceof Cancellation) {
          Cancellation cancellation = (Cancellation) obj;
          Throwable cause = cancellation.cause;
          throw cancellationExceptionWithCause("Task was cancelled.", cause);
        } else if (obj instanceof Failure) {
          Failure failure = (Failure) obj;
    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)
  2. 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 23 01:35:55 GMT 2025
    - 22.1K bytes
    - Click Count (0)
  3. 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 16K bytes
    - Click Count (0)
  4. 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 19.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

            return getValue();
          }
    
          /**
           * Implementation of the actual value retrieval. Will return the value on success, an
           * exception on failure, a cancellation on cancellation, or an illegal state if the
           * synchronizer is in an invalid state.
           */
          private V getValue() throws CancellationException, ExecutionException {
            int state = getState();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

            return getValue();
          }
    
          /**
           * Implementation of the actual value retrieval. Will return the value on success, an
           * exception on failure, a cancellation on cancellation, or an illegal state if the
           * synchronizer is in an invalid state.
           */
          private V getValue() throws CancellationException, ExecutionException {
            int state = getState();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 13.8K bytes
    - Click Count (0)
  7. 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 now
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  8. 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 Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  9. docs/changelogs/changelog_2x.md

        patterns. We also fixed a bug where the cache was being cleared due to a
        corrupted journal. We've added APIs to configure a request's `Cache-Control`
        headers, and to manually clear the cache.
    
     *  **Request cancellation fixes.** This update fixes a bug where synchronous
        requests couldn't be canceled by tag. This update avoids crashing when
        `onResponse()` throws an `IOException`. That failure will now be logged
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 06 02:19:09 GMT 2022
    - 26.6K bytes
    - Click Count (0)
  10. 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 Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Aug 09 01:14:59 GMT 2025
    - 27.7K bytes
    - Click Count (0)
Back to Top