Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 492 for FUTURE (0.26 seconds)

  1. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

        assertFalse(future.isCancelled());
    
        ExecutorService executor = newSingleThreadExecutor();
    
        try {
          Future<Boolean> getResult = executor.submit(() -> future.get());
    
          // Release the future value.
          latch.countDown();
    
          assertTrue(getResult.get(10, SECONDS));
        } finally {
          executor.shutdownNow();
        }
    
        assertTrue(future.isDone());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Jul 11 18:52:30 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetCheckedInputs.java

      static final OtherThrowable OTHER_THROWABLE = new OtherThrowable();
      static final Future<String> FAILED_FUTURE_OTHER_THROWABLE =
          immediateFailedFuture(OTHER_THROWABLE);
      static final Error ERROR = new Error("mymessage");
      static final Future<String> FAILED_FUTURE_ERROR = immediateFailedFuture(ERROR);
      static final Future<String> RUNTIME_EXCEPTION_FUTURE =
          UncheckedThrowingFuture.throwingRuntimeException(RUNTIME_EXCEPTION);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 15:59:55 GMT 2026
    - 6.3K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

     * <p>Useful for testing the behavior of Future utilities against odd futures.
     *
     * @author Anthony Zana
     */
    @GwtCompatible
    @NullUnmarked
    final class UncheckedThrowingFuture<V> extends AbstractFuture<V> {
    
      public static <V> ListenableFuture<V> throwingError(Error error) {
        UncheckedThrowingFuture<V> future = new UncheckedThrowingFuture<V>();
        future.complete(checkNotNull(error));
        return future;
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 3.3K bytes
    - Click Count (0)
  4. android/guava-testlib/test/com/google/common/testing/GcFinalizationTest.java

        SettableFuture<@Nullable Void> future = SettableFuture.create();
        Object unused =
            new Object() {
              @SuppressWarnings({"removal", "Finalize"}) // b/487687332
              @Override
              protected void finalize() {
                future.set(null);
              }
            };
        unused = null; // Hint to the JIT that unused is unreachable
        GcFinalization.awaitDone(future);
        assertTrue(future.isDone());
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 16:11:48 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTester.java

        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    
        assertTrue(latch.await(5, SECONDS));
        assertTrue(future.isDone());
        assertFalse(future.isCancelled());
    
        assertEquals(expectedValue, future.get());
      }
    
      public void testCancelledFuture() throws InterruptedException, ExecutionException {
        assertTrue(future.isDone());
        assertTrue(future.isCancelled());
    
    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)
  6. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

            if (future.listenersField == expect) {
              future.listenersField = update;
              return true;
            }
            return false;
          }
        }
    
        @Override
        @Nullable Listener gasListeners(AbstractFutureState<?> future, Listener update) {
          synchronized (future) {
            Listener old = future.listenersField;
            if (old != update) {
              future.listenersField = update;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        InterruptibleFuture future = new InterruptibleFuture();
        assertTrue(future.cancel(false));
        assertTrue(future.isCancelled());
        assertTrue(future.isDone());
        assertFalse(future.wasInterrupted());
        assertFalse(future.interruptTaskWasCalled);
        CancellationException e = assertThrows(CancellationException.class, future::get);
        assertThat(e).hasCauseThat().isNull();
      }
    
    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)
  8. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

                () -> {
                  Future<?> future = executor.submit(incrementTask);
                  assertTrue(future.isDone());
                  assertEquals(1, threadLocalCount.get().intValue());
                  return null;
                });
        new Thread(otherTask).start();
    
        ListenableFuture<?> future = executor.submit(incrementTask);
        assertTrue(future.isDone());
        assertListenerRunImmediately(future);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top