Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 82 for cancel (0.17 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

        System.clearProperty("guava.concurrent.generate_cancellation_cause");
      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertNull(tryInternalFastPathGetFailure(future));
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/TrustedListenableFutureTaskTest.java

      }
    
      public void testCancelled() throws Exception {
        TrustedListenableFutureTask<Integer> task = TrustedListenableFutureTask.create(returning(2));
        assertFalse(task.isDone());
        task.cancel(false);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
        assertFalse(task.wasInterrupted());
        try {
          getDone(task);
          fail();
        } catch (CancellationException expected) {
        }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 7.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

    /**
     * A {@link ListenableFuture} whose result can be set by a {@link #set(Object)}, {@link
     * #setException(Throwable)} or {@link #setFuture(ListenableFuture)} call. It can also, like any
     * other {@code Future}, be {@linkplain #cancel cancelled}.
     *
     * <p>{@code SettableFuture} is the recommended {@code ListenableFuture} implementation when your
     * task cannot be implemented with {@link ListeningExecutorService}, the various {@link Futures}
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri Oct 01 17:18:04 GMT 2021
    - 2.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            this.lock = lock;
            this.currentFuture = currentFuture;
          }
    
          @Override
          public void cancel(boolean mayInterruptIfRunning) {
            /*
             * Lock to ensure that a task cannot be rescheduled while a cancel is ongoing.
             *
             * In theory, cancel() could execute arbitrary listeners -- bad to do while holding a lock.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

       * of {@link CombinedFuture}, the user-supplied callback usually has its own references to inputs.
       */
      /*
       * In certain circumstances, this field might theoretically not be visible to an afterDone() call
       * triggered by cancel(). For details, see the comments on the fields of TimeoutFuture.
       */
      @CheckForNull @LazyInit
      private ImmutableCollection<? extends ListenableFuture<? extends InputT>> futures;
    
      private final boolean allMustSucceed;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/Futures.java

          this.state = state;
        }
    
        @Override
        public boolean cancel(boolean interruptIfRunning) {
          InCompletionOrderState<T> localState = state;
          if (super.cancel(interruptIfRunning)) {
            /*
             * requireNonNull is generally safe: If cancel succeeded, then this Future was still
             * pending, so its `state` field hasn't been nulled out yet.
             *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 59.6K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/CollectionFuture.java

      /*
       * We access this field racily but safely. For discussion of a similar situation, see the comments
       * on the fields of TimeoutFuture. This field is slightly different from the fields discussed
       * there: cancel() never reads this field, only writes to it. That makes the race here completely
       * harmless, rather than just 99.99% harmless.
       */
      @CheckForNull @LazyInit private List<@Nullable Present<V>> values;
    
      CollectionFuture(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 3.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

          // code should be unreachable with correctly implemented Futures.
          // Cancel this future and return.
          // At this point, inputFuture is cancelled and outputFuture doesn't exist, so the value of
          // mayInterruptIfRunning is irrelevant.
          cancel(false);
          return;
        } catch (ExecutionException e) {
          // Set the cause of the exception as this future's exception.
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

          }
    
          @Override
          public boolean cancel(boolean mayInterruptIfRunning) {
            boolean cancelled = super.cancel(mayInterruptIfRunning);
            if (cancelled) {
              // Unless it is cancelled, the delegate may continue being scheduled
              scheduledDelegate.cancel(mayInterruptIfRunning);
    
              // TODO(user): Cancel "this" if "scheduledDelegate" is cancelled.
            }
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

      }
    
      public void testListenerCalledOnCancelFromRunning() throws Exception {
        exec.execute(task);
        runLatch.await();
    
        // Task has started up, cancel it while it's running.
        task.cancel(true);
        assertTrue(task.isDone());
        assertTrue(task.isCancelled());
        assertEquals(1, taskLatch.getCount());
    
        // Wait for the listeners to be called.
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 4.7K bytes
    - Viewed (0)
Back to top