Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 69 for isCancelled (0.2 sec)

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

        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
        assertEquals(2, getDone(task).intValue());
      }
    
      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());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      }
    
      public void testCancel_notDoneNoInterrupt() throws Exception {
        Future<?> future = newFutureInstance();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertThat(tryInternalFastPathGetFailure(future)).isNull();
        CancellationException e = assertThrows(CancellationException.class, () -> future.get());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        orig.cancel(true);
        assertTrue(orig.isCancelled());
        assertTrue(prev.isCancelled());
        assertTrue(prev.wasInterrupted());
      }
    
      public void testSetFutureSelf_cancel() {
        SettableFuture<String> orig = SettableFuture.create();
        orig.setFuture(orig);
        orig.cancel(true);
        assertTrue(orig.isCancelled());
      }
    
      public void testSetFutureSelf_toString() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 20:45:32 UTC 2025
    - 46.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

      }
    
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate.isDone();
      }
    
      @Override
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        public void cancel(boolean mayInterruptIfRunning) {
          delegate.cancel(mayInterruptIfRunning);
        }
    
        @Override
        public boolean isCancelled() {
          return delegate.isCancelled();
        }
      }
    
      /**
       * A {@link Scheduler} that provides a convenient way for the {@link AbstractScheduledService} to
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ForwardingFluentFuture.java

      }
    
      @Override
      public boolean cancel(boolean mayInterruptIfRunning) {
        return delegate.cancel(mayInterruptIfRunning);
      }
    
      @Override
      public boolean isCancelled() {
        return delegate.isCancelled();
      }
    
      @Override
      public boolean isDone() {
        return delegate.isDone();
      }
    
      @Override
      @ParametricNullness
      public V get() throws InterruptedException, ExecutionException {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
        assertTrue(delegateFuture.isCancelled());
    
        delegateQueue.clear();
    
        future = service.scheduleAtFixedRate(runnable, 5, 5, MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractAbstractFutureTest.java

        assertCannotSet(future);
        assertPending(future);
      }
    
      private static void assertPending(AbstractFuture<Integer> future) {
        assertThat(future.isDone()).isFalse();
        assertThat(future.isCancelled()).isFalse();
    
        CountingRunnable listener = new CountingRunnable();
        future.addListener(listener, directExecutor());
        listener.assertNotRun();
    
        verifyGetOnPendingFuture(future);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 15.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
        assertTrue(delegateFuture.isCancelled());
    
        delegateQueue.clear();
    
        future = service.scheduleAtFixedRate(runnable, 5, 5, MINUTES);
        future.cancel(true);
        assertTrue(future.isCancelled());
        delegateFuture = (ScheduledFuture<?>) delegateQueue.element();
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Fri Dec 12 00:25:21 UTC 2025
    - 26.5K bytes
    - Viewed (0)
  10. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

                future.set(null);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_future_cancel() {
        SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object unused =
            new Object() {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Dec 08 17:02:07 UTC 2025
    - 7.9K bytes
    - Viewed (0)
Back to top