Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 75 for cancel (0.21 sec)

  1. 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());
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

     *       next task will wait for any running callable (or pending {@code Future} returned by an
     *       {@code AsyncCallable}) to complete, without interrupting it (and without calling {@code
     *       cancel} on the {@code Future}). So beware: <i>Even if you cancel every preceding {@code
     *       Future} returned by this class, the next task may still have to wait.</i>.
     *   <li>Once an {@code AsyncCallable} returns a {@code Future}, this class considers that task to
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  3. guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        } catch (TimeoutException expected) {
        } finally {
          latch.countDown();
        }
      }
    
      /**
       * 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());
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 18:30:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetCheckedUntimed_cancelled() throws TwoArgConstructorException {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(
            CancellationException.class, () -> getChecked(future, TwoArgConstructorException.class));
      }
    
      public void testGetCheckedUntimed_ExecutionExceptionChecked() {
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.4K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java

        }
    
        @Override
        public boolean isCancelled() {
          return sync.isCancelled();
        }
    
        @CanIgnoreReturnValue
        @Override
        public boolean cancel(boolean mayInterruptIfRunning) {
          if (!sync.cancel(mayInterruptIfRunning)) {
            return false;
          }
          executionList.execute();
          if (mayInterruptIfRunning) {
            interruptTask();
          }
          return true;
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 13.6K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        try {
          getUnchecked(future);
          fail();
        } catch (CancellationException expected) {
        }
      }
    
      public void testGetUnchecked_ExecutionExceptionChecked() {
        try {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

          valueAndCloser.closeAsync();
        }
        super.waitUntilClosed(closingFuture);
      }
    
      @Override
      void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
        assertThat(closingFuture.cancel(false)).isTrue();
        ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 5.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java

          valueAndCloser.closeAsync();
        }
        super.waitUntilClosed(closingFuture);
      }
    
      @Override
      void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
        assertThat(closingFuture.cancel(false)).isTrue();
        ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
        waitUntilClosed(closingFuture);
        futureCancelled.countDown();
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 5.7K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

        step2Waiter.awaitStarted();
    
        // Everything should still be open.
        assertStillOpen(closeable1, closeable2, closeable3, closeable4);
    
        // Cancel step 3, resume step 2, and pause in step 4.
        assertWithMessage("step3.cancel()").that(step3.cancel(false)).isTrue();
        step2Waiter.awaitReturned();
        step4Waiter.awaitStarted();
    
        // Step 1 is not cancelled because it was done.
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 75.3K bytes
    - Viewed (0)
  10. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
      }
    
      public void testAwaitDone_Future_Cancel() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
              protected void finalize() {
                future.cancel(false);
              }
            };
        x = null; // Hint to the JIT that x is unreachable
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.4K bytes
    - Viewed (0)
Back to top