- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for submitAsync (0.07 seconds)
-
android/guava/src/com/google/common/util/concurrent/Futures.java
* * @throws RejectedExecutionException if the task cannot be scheduled for execution * @since 23.0 */ public static <O extends @Nullable Object> ListenableFuture<O> submitAsync( AsyncCallable<O> callable, Executor executor) { TrustedListenableFutureTask<O> task = TrustedListenableFutureTask.create(callable); executor.execute(task); return task; } /**
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Mar 17 19:26:39 GMT 2026 - 64.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
waitUntilClosed(closingFuture); assertClosed(closeable1, closeable2); } public void testSubmitAsync() throws Exception { ClosingFuture<TestCloseable> closingFuture = ClosingFuture.submitAsync( closer -> { closer.eventuallyClose(closeable1, closingExecutor); return ClosingFuture.submit( new ClosingCallable<TestCloseable>() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
waitUntilClosed(closingFuture); assertClosed(closeable1, closeable2); } public void testSubmitAsync() throws Exception { ClosingFuture<TestCloseable> closingFuture = ClosingFuture.submitAsync( closer -> { closer.eventuallyClose(closeable1, closingExecutor); return ClosingFuture.submit( new ClosingCallable<TestCloseable>() {
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0)