/external/guava/guava-gwt/src-super/java/util/super/java/util/concurrent/ |
Callable.java | 20 * Emulation of Callable. 24 public interface Callable<V> {
|
/libcore/luni/src/main/java/java/util/concurrent/ |
Callable.java | 14 * <p>The <tt>Callable</tt> interface is similar to {@link 21 * convert from other common forms to <tt>Callable</tt> classes. 28 public interface Callable<V> {
|
ExecutorService.java | 103 * submission of a {@code Runnable} or {@code Callable} task to an 188 * {@link Callable} form so they can be submitted. 196 <T> Future<T> submit(Callable<T> task); 246 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 276 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, 298 <T> T invokeAny(Collection<? extends Callable<T>> tasks) 323 <T> T invokeAny(Collection<? extends Callable<T>> tasks,
|
Executors.java | 22 * ThreadFactory}, and {@link Callable} classes defined in this 35 * <li> Methods that create and return a {@link Callable} 37 * in execution methods requiring <tt>Callable</tt>. 297 * Returns a {@link Callable} object that, when 300 * <tt>Callable</tt> to an otherwise resultless action. 303 * @return a callable object 306 public static <T> Callable<T> callable(Runnable task, T result) { method in class:Executors 313 * Returns a {@link Callable} object that, when 316 * @return a callable objec 319 public static Callable<Object> callable(Runnable task) { method in class:Executors 332 public static Callable<Object> callable(final PrivilegedAction<?> action) { method in class:Executors [all...] |
CompletionService.java | 45 Future<V> submit(Callable<V> task);
|
ScheduledExecutorService.java | 88 * @param callable the function to execute 94 * @throws NullPointerException if callable is null 96 public <V> ScheduledFuture<V> schedule(Callable<V> callable,
|
AbstractExecutorService.java | 30 * protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) { 61 * Returns a <tt>RunnableFuture</tt> for the given callable task. 63 * @param callable the callable task being wrapped 65 * underlying callable and which, as a <tt>Future</tt>, will yield 66 * the callable's result as its result and provide for 70 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) { 71 return new FutureTask<T>(callable); 100 public <T> Future<T> submit(Callable<T> task) [all...] |
/external/guava/guava/src/com/google/common/util/concurrent/ |
Callables.java | 19 import java.util.concurrent.Callable; 24 * Static utility methods pertaining to the {@link Callable} interface. 33 * Creates a {@code Callable} which immediately returns a preset value each 36 public static <T> Callable<T> returning(final @Nullable T value) { 37 return new Callable<T>() {
|
ListeningExecutorService.java | 21 import java.util.concurrent.Callable; 41 <T> ListenableFuture<T> submit(Callable<T> task); 69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 86 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
ListenableFutureTask.java | 19 import java.util.concurrent.Callable; 42 * given {@code Callable}. 44 * @param callable the callable task 47 public static <V> ListenableFutureTask<V> create(Callable<V> callable) { 48 return new ListenableFutureTask<V>(callable); 68 private ListenableFutureTask(Callable<V> callable) { 69 super(callable); [all...] |
FakeTimeLimiter.java | 21 import java.util.concurrent.Callable; 43 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration, 45 return callable.call(); // fooled you
|
ForwardingListeningExecutorService.java | 19 import java.util.concurrent.Callable; 39 public <T> ListenableFuture<T> submit(Callable<T> task) {
|
TimeLimiter.java | 21 import java.util.concurrent.Callable; 82 * Invokes a specified Callable, timing out after the specified time limit. 91 * @param callable the Callable to execute 98 * @return the result returned by the Callable 104 <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
|
ForwardingExecutorService.java | 23 import java.util.concurrent.Callable; 55 Collection<? extends Callable<T>> tasks) throws InterruptedException { 61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks) 74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 104 public <T> Future<T> submit(Callable<T> task) {
|
AbstractListeningExecutorService.java | 23 import java.util.concurrent.Callable; 54 @Override public <T> ListenableFuture<T> submit(Callable<T> task) { 63 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks, boolean timed, long nanos) 81 Iterator<? extends Callable<T>> it = tasks.iterator(); 132 @Override public <T> T invokeAny(Collection<? extends Callable<T>> tasks) 142 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 155 for (Callable<T> t : tasks) { 181 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 190 for (Callable<T> t : tasks) [all...] |
/frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
RealMediaPlayerTest.java | 21 import java.util.concurrent.Callable; 34 Callable<MediaPlayer> callable = new Callable<MediaPlayer>() { local 40 FutureTask<MediaPlayer> future = new FutureTask<MediaPlayer>(callable);
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
CallablesTest.java | 21 import java.util.concurrent.Callable; 34 Callable<Object> callable = Callables.returning(value); local 35 assertSame(value, callable.call()); 37 assertSame(value, callable.call());
|
AbstractListeningExecutorServiceTest.java | 24 import java.util.concurrent.Callable; 67 * Completed submit(callable) returns result 104 Future future = e.submit(Executors.callable( 127 Future future = e.submit(Executors.callable( 147 Future future = e.submit(Executors.callable( 176 * submit(null callable) throws NPE 181 e.submit((Callable<?>) null); 187 * submit(callable).get() throws InterruptedException if interrupted 196 final Callable<Void> awaiter = new CheckedCallable<Void>() { 221 * get of submit(callable) throws ExecutionException if callabl [all...] |
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); 34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 38 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit) 41 <T> T invokeAny(Collection<? extends Callable<T>> tasks) 45 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
/cts/libs/util/src/android/cts/util/ |
PollingCheck.java | 19 import java.util.concurrent.Callable; 59 public static void check(CharSequence message, long timeout, Callable<Boolean> condition)
|
/external/robolectric/src/main/java/com/xtremelabs/robolectric/util/ |
RobolectricBackgroundExecutorService.java | 7 import java.util.concurrent.Callable; 42 public <T> Future<T> submit(Callable<T> tCallable) { 68 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException { 73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException { 78 public <T> T invokeAny(Collection<? extends Callable<T>> callables) throws InterruptedException, ExecutionException { 83 public <T> T invokeAny(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {
|
/external/jmonkeyengine/engine/src/core/com/jme3/asset/ |
ThreadingManager.java | 35 import java.util.concurrent.Callable; 69 protected class LoadingTask implements Callable<Object> { 79 // protected class MultiLoadingTask implements Callable<Void> {
|
/ndk/tests/device/issue35933-lambda/jni/ |
issue35933-lambda.cpp | 17 template <class Callable, typename... ArgTypes> 18 void* Call(Callable native_func, ArgTypes&&... args) noexcept
|
/cts/tests/tests/app/src/android/app/cts/ |
IntentServiceTest.java | 26 import java.util.concurrent.Callable; 62 new Callable<Boolean>() { 69 PollingCheck.check("accumulator not correct", TIMEOUT_MSEC, new Callable<Boolean>() { 76 PollingCheck.check("onDestroyCalled not called", TIMEOUT_MSEC, new Callable<Boolean>() {
|
/external/junit/src/org/junit/rules/ |
ErrorCollector.java | 10 import java.util.concurrent.Callable; 64 checkSucceeds(new Callable<Object>() { 73 * Adds to the table the exception, if any, thrown from {@code callable}. 75 * {@code callable} threw an exception. 77 public Object checkSucceeds(Callable<Object> callable) { 79 return callable.call();
|