Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 43 for SettableFuture (0.06 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/util/concurrent/SettableFuture.java

     */
    @GwtCompatible
    public final class SettableFuture<V extends @Nullable Object>
        extends AbstractFuture.TrustedFuture<V> {
      /**
       * Creates a new {@code SettableFuture} that can be completed or cancelled by a later method call.
       */
      public static <V extends @Nullable Object> SettableFuture<V> create() {
        return new SettableFuture<>();
      }
    
      @CanIgnoreReturnValue
      @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2.3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<Object> async = SettableFuture.create();
        SettableFuture<Object> inner = SettableFuture.create();
        async.setFuture(inner);
        async.cancel(false);
        assertTrue(inner.isCancelled());
        assertFalse(inner.wasInterrupted());
        assertThrows(CancellationException.class, inner::get);
      }
    
      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<Object> async = SettableFuture.create();
        SettableFuture<Object> inner = SettableFuture.create();
        async.setFuture(inner);
        async.cancel(false);
        assertTrue(inner.isCancelled());
        assertFalse(inner.wasInterrupted());
        assertThrows(CancellationException.class, inner::get);
      }
    
      public void testCancel_beforeSet() throws Exception {
        SettableFuture<Object> async = SettableFuture.create();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        }
        settableFuture.set(null);
        getDone(allAsList(results));
      }
    
      public void testAvoidsStackOverflow_manyCancelled() throws Exception {
        SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ListenableFuture<@Nullable Void> unused =
            serializer.submitAsync(() -> settableFuture, directExecutor());
        for (int i = 0; i < 50_000; i++) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

        }
        settableFuture.set(null);
        getDone(allAsList(results));
      }
    
      public void testAvoidsStackOverflow_manyCancelled() throws Exception {
        SettableFuture<@Nullable Void> settableFuture = SettableFuture.create();
        ListenableFuture<@Nullable Void> unused =
            serializer.submitAsync(() -> settableFuture, directExecutor());
        for (int i = 0; i < 50_000; i++) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

      public void testSameThreadSuccess() {
        SettableFuture<String> f = SettableFuture.create();
        MockCallback callback = new MockCallback("foo");
        addCallback(f, callback, directExecutor());
        f.set("foo");
      }
    
      public void testExecutorSuccess() {
        CountingSameThreadExecutor ex = new CountingSameThreadExecutor();
        SettableFuture<String> f = SettableFuture.create();
        MockCallback callback = new MockCallback("foo");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/FutureCallbackTest.java

      public void testSameThreadSuccess() {
        SettableFuture<String> f = SettableFuture.create();
        MockCallback callback = new MockCallback("foo");
        addCallback(f, callback, directExecutor());
        f.set("foo");
      }
    
      public void testExecutorSuccess() {
        CountingSameThreadExecutor ex = new CountingSameThreadExecutor();
        SettableFuture<String> f = SettableFuture.create();
        MockCallback callback = new MockCallback("foo");
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      // together.  Now it should only be limited by available memory (and time)
      public void testSetFuture_stackOverflow() {
        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java

        SettableFuture<String> future = SettableFuture.create();
        FutureTask<Boolean> interruptReporter = untimedInterruptReporter(future, false);
    
        runNInterruptsTest(times, future, interruptReporter);
      }
    
      private static void runTimedInterruptsTest(int times)
          throws InterruptedException, ExecutionException, TimeoutException {
        SettableFuture<String> future = SettableFuture.create();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.9K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

      // together.  Now it should only be limited by available memory (and time)
      public void testSetFuture_stackOverflow() {
        SettableFuture<String> orig = SettableFuture.create();
        SettableFuture<String> prev = orig;
        for (int i = 0; i < 100000; i++) {
          SettableFuture<String> curr = SettableFuture.create();
          prev.setFuture(curr);
          prev = curr;
        }
        // prev represents the 'innermost' future
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 45.2K bytes
    - Click Count (0)
Back to Top