- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 908 for Callable (0.19 sec)
-
android/guava/src/com/google/common/util/concurrent/AbstractListeningExecutorService.java
*/ @CanIgnoreReturnValue // TODO(kak): consider removing this @Override protected final <T extends @Nullable Object> RunnableFuture<T> newTaskFor(Callable<T> callable) { return TrustedListenableFutureTask.create(callable); } @CanIgnoreReturnValue // TODO(kak): consider removing this @Override public ListenableFuture<?> submit(Runnable task) { return (ListenableFuture<?>) super.submit(task);
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 12 18:32:03 GMT 2023 - 3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
private static final String GOOD_CALLABLE_RESULT = "good callable result"; private static final Callable<String> GOOD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
* <p>Cancellation does not propagate from the output future to a callable that has begun to * execute, but if the output future is cancelled before {@link Callable#call()} is invoked, * {@link Callable#call()} will not be invoked. */ public <T extends @Nullable Object> ListenableFuture<T> submit( Callable<T> callable, Executor executor) { checkNotNull(callable); checkNotNull(executor); return submitAsync(
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-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Tue Feb 13 14:28:25 GMT 2024 - 46.8K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SimpleTimeLimiterTest.java
private static final String GOOD_CALLABLE_RESULT = "good callable result"; private static final Callable<String> GOOD_CALLABLE = new Callable<String>() { @Override public String call() throws InterruptedException { MILLISECONDS.sleep(DELAY_MS); return GOOD_CALLABLE_RESULT; } }; private static final Callable<String> BAD_CALLABLE = new Callable<String>() {
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ForwardingExecutorService.java
} @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks) throws InterruptedException { return delegate().invokeAll(tasks); } @Override public <T extends @Nullable Object> List<Future<T>> invokeAll( Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) throws InterruptedException {
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) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
return true; } @Override public void execute(Runnable runnable) {} @Override public <V> ListenableScheduledFuture<V> schedule( Callable<V> callable, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
guava/src/com/google/common/cache/Cache.java
import com.google.errorprone.annotations.DoNotMock; import java.util.Map; import java.util.concurrent.Callable; import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ExecutionException; import javax.annotation.CheckForNull; /** * A semi-persistent mapping from keys to values. Cache entries are manually added using {@link * #get(Object, Callable)} or {@link #put(Object, Object)}, and are stored in the cache until either
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Sun Aug 07 02:38:22 GMT 2022 - 7.9K bytes - Viewed (1) -
guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java
} } private static List<Callable<String>> createTasks(int n) { List<Callable<String>> callables = Lists.newArrayList(); for (int i = 0; i < n; i++) { callables.add(Callables.returning(RESULT_VALUE + i)); } return callables; } private static final class WrappedCallable<T> implements Callable<T> { private final Callable<T> delegate;
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) -
guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
import static java.util.concurrent.TimeUnit.SECONDS; import static org.junit.Assert.assertThrows; import com.google.common.testing.TearDown; import com.google.common.testing.TearDownStack; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.FutureTask;
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 9.1K bytes - Viewed (0)