Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 13 for SettableFuture (0.07 seconds)

  1. 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)
  2. 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)
  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
    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)
  4. 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)
  5. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        assertThat(getChecked(immediateFuture("foo"), TwoArgConstructorException.class))
            .isEqualTo("foo");
      }
    
      public void testGetCheckedUntimed_interrupted() {
        SettableFuture<String> future = SettableFuture.create();
        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class);
          fail();
        } catch (TwoArgConstructorException expected) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 16.5K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        assertThat(getChecked(immediateFuture("foo"), TwoArgConstructorException.class))
            .isEqualTo("foo");
      }
    
      public void testGetCheckedUntimed_interrupted() {
        SettableFuture<String> future = SettableFuture.create();
        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class);
          fail();
        } catch (TwoArgConstructorException expected) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 16.5K bytes
    - Click Count (0)
  7. android/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);
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
  8. 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);
        }
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 10K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        } finally {
          service.shutdown();
        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        CountDownLatch latch = new CountDownLatch(1);
        SettableFuture<?> future = SettableFuture.create();
        Executor delegate =
            new Executor() {
              @Override
              public void execute(Runnable task) {
                if (future.set(null)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        } finally {
          service.shutdown();
        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        CountDownLatch latch = new CountDownLatch(1);
        SettableFuture<?> future = SettableFuture.create();
        Executor delegate =
            new Executor() {
              @Override
              public void execute(Runnable task) {
                if (future.set(null)) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
Back to Top