- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 687 for future (0.15 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractCatchingFuture.java
Class<X> exceptionType, Function<? super X, ? extends V> fallback, Executor executor) { CatchingFuture<V, X> future = new CatchingFuture<>(input, exceptionType, fallback); input.addListener(future, rejectionPropagatingExecutor(executor, future)); return future; } static <X extends Throwable, V extends @Nullable Object> ListenableFuture<V> create( ListenableFuture<? extends V> input,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 8.7K bytes - Viewed (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * <pre>{@code * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name); * future.addListener(new Runnable() { * public void run() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* Future} is "completed" even if it is cancelled while its underlying work continues on a * thread, an RPC, etc. The {@code Future} is also "completed" if it fails "early" -- for * example, if the deadline expires on a {@code Future} returned from {@link * Futures#withTimeout} while the {@code Future} it wraps continues its underlying work. So
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/SimpleTimeLimiter.java
checkNotNull(timeoutUnit); checkPositiveTimeout(timeoutDuration); Future<T> future = executor.submit(callable); try { return amInterruptible ? future.get(timeoutDuration, timeoutUnit) : getUninterruptibly(future, timeoutDuration, timeoutUnit); } catch (InterruptedException e) { future.cancel(true); throw e; } catch (ExecutionException e) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jun 27 14:21:11 GMT 2023 - 9.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
return i; } }; List<Future<Integer>> futures = executor.invokeAll(Collections.nCopies(10, incrementTask)); for (int i = 0; i < 10; i++) { Future<Integer> future = futures.get(i); assertTrue("Task should have been run before being returned", future.isDone()); assertEquals(i, future.get().intValue()); }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K bytes - Viewed (3) -
android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java
} /** * Invokes {@code future.}{@link Future#get() get()} uninterruptibly. * * <p>Similar methods: * * <ul> * <li>To retrieve a result from a {@code Future} that is already done, use {@link * Futures#getDone Futures.getDone}. * <li>To treat {@link InterruptedException} uniformly with other exceptions, use {@link * Futures#getChecked(Future, Class) Futures.getChecked}.
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 14.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AsyncCallable.java
* result. * * @since 20.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface AsyncCallable<V extends @Nullable Object> { /** * Computes a result {@code Future}. The output {@code Future} need not be {@linkplain * Future#isDone done}, making {@code AsyncCallable} suitable for asynchronous derivations. * * <p>Throwing an exception from this method is equivalent to returning a failing {@link
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Dec 14 15:53:12 GMT 2021 - 1.5K bytes - Viewed (0) -
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 = TimeUnit.SECONDS; long timeout = 5; TestExecutor testExecutor = new TestExecutor(mock); List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Jan 05 19:41:03 GMT 2023 - 9.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* result. (If you want such access, you may prefer {@link Futures#addCallback * Futures.addCallback}.) Still, direct {@code addListener} calls are occasionally useful: * * <pre>{@code * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name); * future.addListener(new Runnable() { * public void run() {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jun 26 21:13:41 GMT 2023 - 8K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxerTest.java
List<Future<ProjectSegment>> futures = new ArrayList<>(); for (ProjectSegment projectBuild : projectBuildList) { final Future<ProjectSegment> buildFuture = service.submit(new Outputter(threadOutputMuxer, projectBuild, lyrics.next())); futures.add(buildFuture); } for (Future<ProjectSegment> future : futures) { future.get();
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 6.6K bytes - Viewed (0)