Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 51 for SettableFuture (0.19 sec)

  1. android/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();
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/FluentFutureTest.java

      public void testFromFluentFuture() {
        FluentFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
      public void testFromFluentFuturePassingAsNonFluent() {
        ListenableFuture<String> f = FluentFuture.from(SettableFuture.<String>create());
        assertThat(FluentFuture.from(f)).isSameInstanceAs(f);
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 5.7K bytes
    - Viewed (0)
  3. 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
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 46.8K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        assertEquals("foo", getChecked(immediateFuture("foo"), TwoArgConstructorException.class));
      }
    
      public void testGetCheckedUntimed_interrupted() {
        SettableFuture<String> future = SettableFuture.create();
        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class);
          fail();
        } catch (TwoArgConstructorException expected) {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.4K bytes
    - Viewed (0)
  5. 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
    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)
  6. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      protected static final int SLOW_OUTPUT_VALID_INPUT_DATA = 2;
      protected static final int SLOW_FUNC_VALID_INPUT_DATA = 3;
      private static final String RESULT_DATA = "SUCCESS";
    
      private SettableFuture<String> outputFuture;
      // Signals that the function is waiting to complete
      private CountDownLatch funcIsWaitingLatch;
      // Signals the function so it will complete
      private CountDownLatch funcCompletionLatch;
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

      private Class<?> settableFutureClass;
      private Class<?> abstractFutureClass;
    
      @Override
      protected void setUp() throws Exception {
        // Load the "normal" copy of SettableFuture and related classes.
        SettableFuture<?> unused = SettableFuture.create();
        // Hack to load AbstractFuture et. al. in a new classloader so that it re-reads the cancellation
    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)
  8. guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

            };
        x = null; // Hint to the JIT that x is unreachable
        GcFinalization.await(latch);
        assertEquals(0, latch.getCount());
      }
    
      public void testAwaitDone_Future() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
              protected void finalize() {
                future.set(null);
              }
            };
    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)
  9. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

            };
        x = null; // Hint to the JIT that x is unreachable
        GcFinalization.await(latch);
        assertEquals(0, latch.getCount());
      }
    
      public void testAwaitDone_Future() {
        final SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object x =
            new Object() {
              @Override
              protected void finalize() {
                future.set(null);
              }
            };
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 7.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java

        static <V> NonListenableSettableFuture<V> create() {
          return new NonListenableSettableFuture<V>();
        }
    
        final SettableFuture<V> delegate = SettableFuture.create();
    
        @Override
        protected Future<V> delegate() {
          return delegate;
        }
    
        void set(V value) {
          delegate.set(value);
        }
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 9.7K bytes
    - Viewed (0)
Back to top