Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 442 for Future (0.04 sec)

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

      public boolean setException(Throwable throwable) {
        return super.setException(throwable);
      }
    
      @CanIgnoreReturnValue
      @Override
      public boolean setFuture(ListenableFuture<? extends V> future) {
        return super.setFuture(future);
      }
    
      private SettableFuture() {}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. 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) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 2.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/FutureCallback.java

      /** Invoked with the result of the {@code Future} computation when it is successful. */
      void onSuccess(@ParametricNullness V result);
    
      /**
       * Invoked when a {@code Future} computation fails or is canceled.
       *
       * <p>If the future's {@link Future#get() get} method throws an {@link ExecutionException}, then
       * the cause is passed to this method. Any other thrown object is passed unaltered.
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java

        String key = "key";
    
        AtomicLongMap<String> map = AtomicLongMap.create();
    
        ExecutorService threadPool = newFixedThreadPool(nThreads);
        ArrayList<Future<Long>> futures = new ArrayList<>();
        for (int i = 0; i < nTasks; i++) {
          futures.add(
              threadPool.submit(
                  new Callable<Long>() {
                    @Override
                    public Long call() {
                      long threadSum = 0;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/testing/GcFinalization.java

      }
    
      /**
       * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage collector
       * as necessary to try to ensure that this will happen.
       *
       * @throws RuntimeException if timed out or interrupted while waiting
       */
      @SuppressWarnings("removal") // b/260137033
      public static void awaitDone(Future<?> future) {
        if (future.isDone()) {
          return;
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 11.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(CancellationException.class, () -> getUnchecked(future));
      }
    
      public void testGetUnchecked_executionExceptionChecked() {
        UncheckedExecutionException expected =
            assertThrows(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
        SettableFuture<String> future = SettableFuture.create();
        future.cancel(true);
        assertThrows(CancellationException.class, () -> getUnchecked(future));
      }
    
      public void testGetUnchecked_executionExceptionChecked() {
        UncheckedExecutionException expected =
            assertThrows(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AbstractTransformFuture.java

         * Future, then a call setException() would likely also overflow.
         *
         * - If the stack overflowed after set()/setValue() stored its result, then a call to
         * setException() will be a no-op because the Future is already done.
         *
         * Both scenarios are bad: The output Future might never complete, or, if it does complete, it
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 20 18:03:37 UTC 2025
    - 10.8K bytes
    - Viewed (0)
  9. 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());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  10. 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());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 3.7K bytes
    - Viewed (0)
Back to top