- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for AsyncCallable (0.39 sec)
-
android/guava/src/com/google/common/util/concurrent/AsyncCallable.java
* Futures.FutureCombiner#callAsync(AsyncCallable, java.util.concurrent.Executor)}. * * <p>Much like {@link java.util.concurrent.Callable}, but returning a {@link ListenableFuture} * result. * * @since 20.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public interface AsyncCallable<V extends @Nullable Object> { /**
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) -
android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
assertFalse(functionCalled.get()); } public void testSubmitAsync_asyncCallable_error() throws InterruptedException { final Error error = new Error("deliberate"); AsyncCallable<Integer> callable = new AsyncCallable<Integer>() { @Override public ListenableFuture<Integer> call() { throw error; }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
@Override public String call() throws Exception { return expected; } }; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, MoreExecutors.newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); assertSame(expected, future.get()); } @J2ktIncompatible @GwtIncompatible
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
@Override public String call() throws Exception { return expected; } }; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, MoreExecutors.newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); assertSame(expected, future.get()); } @J2ktIncompatible @GwtIncompatible
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 5.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/FuturesTest.java
assertFalse(functionCalled.get()); } public void testSubmitAsync_asyncCallable_error() throws InterruptedException { final Error error = new Error("deliberate"); AsyncCallable<Integer> callable = new AsyncCallable<Integer>() { @Override public ListenableFuture<Integer> call() { throw error; }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 20 17:00:05 GMT 2024 - 144.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
} @WeakOuter private final class AsyncCallableInterruptibleTask extends CombinedFutureInterruptibleTask<ListenableFuture<V>> { private final AsyncCallable<V> callable; AsyncCallableInterruptibleTask(AsyncCallable<V> callable, Executor listenerExecutor) { super(listenerExecutor); this.callable = checkNotNull(callable); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* callable} or a callable that has begun to execute, but if the output future is cancelled before * {@link AsyncCallable#call()} is invoked, {@link AsyncCallable#call()} will not be invoked. */ public <T extends @Nullable Object> ListenableFuture<T> submitAsync( AsyncCallable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor);
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) -
guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
@Override public Integer apply(Integer input) { return input + delta; } }; } private static AsyncCallable<Integer> asyncAdd( final ListenableFuture<Integer> future, final int delta, final Executor executor) { return new AsyncCallable<Integer>() { @Override public ListenableFuture<Integer> call() throws Exception {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java
@Override public Integer apply(Integer input) { return input + delta; } }; } private static AsyncCallable<Integer> asyncAdd( final ListenableFuture<Integer> future, final int delta, final Executor executor) { return new AsyncCallable<Integer>() { @Override public ListenableFuture<Integer> call() throws Exception {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 16.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TrustedListenableFutureTask.java
} } @WeakOuter private final class TrustedFutureInterruptibleAsyncTask extends InterruptibleTask<ListenableFuture<V>> { private final AsyncCallable<V> callable; TrustedFutureInterruptibleAsyncTask(AsyncCallable<V> callable) { this.callable = checkNotNull(callable); } @Override final boolean isDone() { return TrustedListenableFutureTask.this.isDone();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri Oct 01 17:18:04 GMT 2021 - 5.6K bytes - Viewed (0)