Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 20 for cancellation (0.18 seconds)

  1. 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)
  2. 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)
  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 Dec 26 12:43:10 GMT 2025
    - 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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  5. 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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  6. 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)
  7. 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 Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 20 18:03:37 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top