- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 201 for Future (0.8 sec)
-
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
delegate().execute(command); } @Override public <T extends @Nullable Object> Future<T> submit(Callable<T> task) { return delegate().submit(task); } @Override public Future<?> submit(Runnable task) { return delegate().submit(task); } @Override public <T extends @Nullable Object> Future<T> submit( Runnable task, @ParametricNullness T result) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.1K bytes - Viewed (0) -
futures/failureaccess/src/com/google/common/util/concurrent/internal/InternalFutures.java
* return value of this method as its cause * </ul> */ public static Throwable tryInternalFastPathGetFailure(InternalFutureFailureAccess future) { return future.tryInternalFastPathGetFailure(); } private InternalFutures() {}
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 1.7K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java
return delegate.submit(task); } @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException { Preconditions.checkNotNull(tasks, "tasks must not be null!"); return delegate.invokeAll(tasks); } @Override public <T> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Oct 06 00:47:57 GMT 2021 - 6.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapBasherTest.java
final AtomicLongMap<String> map = AtomicLongMap.create(); ExecutorService threadPool = Executors.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;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 4.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
} }; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, MoreExecutors.newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); assertSame(expected, future.get()); } @J2ktIncompatible @GwtIncompatible public void testAsAsyncCallable_exception() throws Exception { final Exception expected = new IllegalArgumentException();
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) -
guava-tests/test/com/google/common/cache/CacheLoaderTest.java
import com.google.common.collect.ImmutableMap; import com.google.common.collect.Queues; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; import java.util.Deque; import java.util.Map; import java.util.concurrent.Executor; import java.util.concurrent.Future; import java.util.concurrent.atomic.AtomicInteger; import junit.framework.TestCase; /**
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri Aug 05 17:21:46 GMT 2022 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
import java.util.concurrent.Future; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Implementation of {@code Futures#withTimeout}. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java
} }; AsyncCallable<String> asyncCallable = Callables.asAsyncCallable(callable, MoreExecutors.newDirectExecutorService()); ListenableFuture<String> future = asyncCallable.call(); assertSame(expected, future.get()); } @J2ktIncompatible @GwtIncompatible public void testAsAsyncCallable_exception() throws Exception { final Exception expected = new IllegalArgumentException();
Java - Registered: Fri May 03 12:43:13 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/ListeningExecutorServiceTest.java
} public void testInvokeAll() throws Exception { Set<Callable<String>> tasks = Collections.singleton(() -> "invokeAll"); List<Future<String>> result = executorService.invokeAll(tasks, Duration.ofDays(365)); assertThat(result).hasSize(1); assertThat(Futures.getDone(result.get(0))).isEqualTo("invokeAll"); assertThat(recordedTasks).isSameInstanceAs(tasks); assertThat(recordedTimeUnit).isEqualTo(NANOSECONDS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Fri Jun 02 12:45:23 GMT 2023 - 4.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/WrappingExecutorService.java
} @Override public final <T extends @Nullable Object> Future<T> submit(Callable<T> task) { return delegate.submit(wrapTask(checkNotNull(task))); } @Override public final Future<?> submit(Runnable task) { return delegate.submit(wrapTask(task)); } @Override public final <T extends @Nullable Object> Future<T> submit( Runnable task, @ParametricNullness T result) {
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 5.5K bytes - Viewed (0)