- Sort Score
- Num 10 results
- Language All
Results 61 - 70 of 746 for future (0.04 seconds)
-
android/guava/src/com/google/common/util/concurrent/AsyncFunction.java
/** * Returns an output {@code Future} to use in place of the given {@code input}. The output {@code * Future} need not be {@linkplain Future#isDone done}, making {@code AsyncFunction} suitable for * asynchronous derivations. * * <p>Throwing an exception from this method is equivalent to returning a failing {@code Future}. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0) -
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() {}
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.3K bytes - Click Count (0) -
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) -
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) -
android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
List<Future<String>> futures = testExecutor.invokeAll(tasks); mock.assertLastMethodCalled("invokeAll"); checkResults(futures); } { MockExecutor mock = new MockExecutor(); TimeUnit unit = SECONDS; long timeout = 5; TestExecutor testExecutor = new TestExecutor(mock); List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 10.1K bytes - Click Count (0) -
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. */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 1.5K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
@GwtIncompatible public class MockFutureListener implements Runnable { private final CountDownLatch countDownLatch; private final ListenableFuture<?> future; public MockFutureListener(ListenableFuture<?> future) { this.countDownLatch = new CountDownLatch(1); this.future = future; future.addListener(this, directExecutor()); } @Override public void run() { countDownLatch.countDown(); } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Fri May 12 18:12:42 GMT 2023 - 3K bytes - Click Count (0) -
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) -
guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java
} @Override public <T> Future<T> submit(Callable<T> task) { throw new UnsupportedOperationException(); } @Override public Future<?> submit(Runnable task) { throw new UnsupportedOperationException(); } @Override public <T> Future<T> submit(Runnable task, T result) { throw new UnsupportedOperationException(); }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 7.5K bytes - Click Count (0) -
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
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Feb 20 18:03:37 GMT 2025 - 10.8K bytes - Click Count (0)