Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 151 - 160 of 1,134 for futures (0.04 seconds)

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

      @Override
      AbstractFuture<@Nullable Integer> newDelegate() {
        AbstractFuture<@Nullable Integer> future = new AbstractFuture<@Nullable Integer>() {};
        assertFalse(future instanceof TrustedFuture); // sanity check
        return future;
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 1.3K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<Integer> future = SettableFuture.create();
        assertTrue(future.set(42));
        // Later attempts to set the future should return false.
        assertFalse(future.set(23));
        assertFalse(future.setException(new Exception("bar")));
        assertFalse(future.setFuture(SettableFuture.create()));
        // Check that the future has been set properly.
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    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-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFutureState.java

        Listener old = listeners;
        listeners = update;
        return old;
      }
    
      static boolean casValue(AbstractFutureState<?> future, @Nullable Object expect, Object update) {
        if (future.value == expect) {
          future.value = update;
          return true;
        }
        return false;
      }
    
      final @Nullable Object value() {
        return value;
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Feb 21 02:38:37 GMT 2025
    - 1.9K bytes
    - Click Count (0)
  4. futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutures.java

       *       return value of this method as its cause
       * </ul>
       */
      public static
          Throwable
          tryInternalFastPathGetFailure(InternalFutureFailureAccess future) {
        return future.tryInternalFastPathGetFailure();
      }
    
      private InternalFutures() {}
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Jan 18 02:54:30 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  5. 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);
        assertThat(e.getCause()).isNotNull();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  6. 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);
        assertThat(e.getCause()).isNotNull();
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/TestPlatform.java

      /**
       * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long,
       * TimeUnit)} overload in order to test that method.
       */
      static <V extends @Nullable Object> V getDoneFromTimeoutOverload(Future<V> future)
          throws ExecutionException {
        checkState(future.isDone(), "Future was expected to be done: %s", future);
        try {
          return getUninterruptibly(future, 0, SECONDS);
        } catch (TimeoutException e) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  8. android/guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

            () -> {
              taskDone = true;
              return taskDone;
            };
        List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, MILLISECONDS);
        Future<Boolean> future = futureList.get(0);
        assertFalse(taskDone);
        assertTrue(future.isDone());
        assertThrows(CancellationException.class, future::get);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  9. guava-testlib/test/com/google/common/util/concurrent/testing/TestingExecutorsTest.java

            () -> {
              taskDone = true;
              return taskDone;
            };
        List<Future<Boolean>> futureList = executor.invokeAll(ImmutableList.of(task), 10, MILLISECONDS);
        Future<Boolean> future = futureList.get(0);
        assertFalse(taskDone);
        assertTrue(future.isDone());
        assertThrows(CancellationException.class, future::get);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 3.3K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/SettableFutureTest.java

        SettableFuture<Integer> future = SettableFuture.create();
        assertTrue(future.set(42));
        // Later attempts to set the future should return false.
        assertFalse(future.set(23));
        assertFalse(future.setException(new Exception("bar")));
        assertFalse(future.setFuture(SettableFuture.create()));
        // Check that the future has been set properly.
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    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)
Back to Top