Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 27 for Cancellation (0.36 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-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class AbstractFutureCancellationCauseTest extends TestCase {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

    import java.util.concurrent.Future;
    import java.util.concurrent.TimeUnit;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /** Tests for {@link AbstractFuture} with the cancellation cause system property set */
    @AndroidIncompatible // custom classloading
    
    @NullUnmarked
    @GwtIncompatible
    @J2ktIncompatible
    public class AbstractFutureCancellationCauseTest extends TestCase {
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      /**
       * Tests that a canceled future throws a cancellation exception.
       *
       * <p>This method checks the cancel, isCancelled, and isDone methods.
       */
      public void testCanceledFutureThrowsCancellation() throws Exception {
    
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      /**
       * Tests that a canceled future throws a cancellation exception.
       *
       * <p>This method checks the cancel, isCancelled, and isDone methods.
       */
      public void testCanceledFutureThrowsCancellation() throws Exception {
    
        assertFalse(future.isDone());
        assertFalse(future.isCancelled());
    
        CountDownLatch successLatch = new CountDownLatch(1);
    
        // Run cancellation in a separate thread as an extra thread-safety test.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/Futures.java

     * Futures#transform(ListenableFuture, Function, Executor) Futures.transform}, but 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: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  8. 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)
  9. 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)
  10. 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)
Back to Top