| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListenableFutureTask.java | 19 import java.util.concurrent.Callable;
47 * given {@code Callable}.
49 * @param callable the callable task
52 public static <V> ListenableFutureTask<V> create(Callable<V> callable) {
53 return new ListenableFutureTask<V>(callable);
73 ListenableFutureTask(Callable<V> callable) {
74 super(callable);
[all...] |
| 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) {
|
| FakeTimeLimiter.java | 23 import java.util.concurrent.Callable;
48 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
51 return callable.call(); // fooled you
|
| ListeningScheduledExecutorService.java | 21 import java.util.concurrent.Callable;
46 Callable<V> callable, long delay, TimeUnit unit);
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/perf/ |
| InstrumentationTimeScenario.java | 14 import java.util.concurrent.Callable;
36 protected Callable<Void> getInstrumentedCallable() throws Exception {
39 return new Callable<Void>() {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| ScheduledTrial.java | 17 import java.util.concurrent.Callable;
45 Callable<TrialResult> trialTask() {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| CallablesTest.java | 25 import java.util.concurrent.Callable;
38 Callable<Object> callable = Callables.returning(value); local
39 assertSame(value, callable.call());
41 assertSame(value, callable.call());
47 Callable<Void> callable = new Callable<Void>() { local
53 Callables.threadRenaming(callable, newName).call();
61 Callable<Void> callable = new Callable<Void>() local
86 Callable<Void> callable = new Callable<Void>() { local
[all...] |
| WrappingExecutorServiceTest.java | 32 import java.util.concurrent.Callable;
88 Callable<String> task = Callables.returning(RESULT_VALUE);
96 List<Callable<String>> tasks = createTasks(3);
116 List<Callable<String>> tasks = createTasks(3);
142 private static List<Callable<String>> createTasks(int n) {
143 List<Callable<String>> callables = Lists.newArrayList();
150 private static final class WrappedCallable<T> implements Callable<T> {
151 private final Callable<T> delegate;
153 public WrappedCallable(Callable<T> delegate) {
182 protected <T> Callable<T> wrapTask(Callable<T> callable)
[all...] |
| /frameworks/base/packages/StatementService/src/com/android/statementservice/ |
| ExceptionLoggingFutureTask.java | 21 import java.util.concurrent.Callable;
32 public ExceptionLoggingFutureTask(Callable<V> callable, String tag) {
33 super(callable);
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| Executors.java | 56 * ThreadFactory}, and {@link Callable} classes defined in this
69 * <li>Methods that create and return a {@link Callable}
71 * in execution methods requiring {@code Callable}.
368 * Returns a {@link Callable} object that, when
371 * {@code Callable} to an otherwise resultless action.
375 * @return a callable object
378 public static <T> Callable<T> callable(Runnable task, T result) { method in class:Executors
385 * Returns a {@link Callable} object that, when
388 * @return a callable objec
391 public static Callable<Object> callable(Runnable task) { method in class:Executors
404 public static Callable<Object> callable(final PrivilegedAction<?> action) { method in class:Executors
[all...] |
| CompletionService.java | 73 Future<V> submit(Callable<V> task);
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| SimplePerRealmReloadingClassLoader.java | 8 import java.util.concurrent.Callable;
87 if (instance instanceof Callable) {
88 Callable<?> callableInRealm = (Callable<?>) instance;
94 throw new IllegalArgumentException("qualified name '" + callableCalledInClassLoaderRealm + "' should represent a class implementing Callable");
103 if (instance instanceof Callable) {
104 Callable<?> callableInRealm = (Callable<?>) instance;
111 throw new IllegalArgumentException("qualified name '" + callableCalledInClassLoaderRealm + "' should represent a class implementing Callable");
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| AbstractExecutorServiceTest.java | 20 import java.util.concurrent.Callable;
82 * Completed submit(callable) returns result
118 Future future = e.submit(Executors.callable(new PrivilegedAction() {
139 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
157 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
184 * submit(null callable) throws NPE
189 e.submit((Callable) null);
195 * submit(callable).get() throws InterruptedException if interrupted
200 final Callable<Void> awaiter = new CheckedCallable<Void>() {
223 * get of submit(callable) throws ExecutionException if callabl
[all...] |
| /external/robolectric/v1/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 {
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/util/ |
| BrNameUtil.java | 19 import android.databinding.tool.reflection.Callable;
43 public static String brKey(Callable callable) {
44 if (callable.type == Callable.Type.FIELD) {
45 return stripPrefixFromField(callable.name);
48 final String name = callable.name;
49 if (isGetter(callable) || isSetter(callable)) {
51 } else if (isBooleanGetter(callable)) {
[all...] |
| /cts/common/device-side/util/src/com/android/compatibility/common/util/ |
| PollingCheck.java | 19 import java.util.concurrent.Callable;
63 public static void check(CharSequence message, long timeout, Callable<Boolean> condition)
|
| /cts/tests/tests/location/src/android/location/cts/ |
| TestUtils.java | 19 import java.util.concurrent.Callable;
50 public static boolean waitForWithCondition(int timeInSec, Callable<Boolean> callback)
|
| /external/jacoco/org.jacoco.agent.rt/src/org/jacoco/agent/rt/internal/ |
| JmxRegistration.java | 15 import java.util.concurrent.Callable;
27 class JmxRegistration implements Callable<Void> {
|
| /external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| MockMethodDispatcher.java | 8 import java.util.concurrent.Callable;
28 public abstract Callable<?> handle(Object instance, Method origin, Object[] arguments) throws Throwable;
|
| /external/sl4a/Utils/src/com/googlecode/android_scripting/ |
| MainThread.java | 24 import java.util.concurrent.Callable;
36 public static <T> T run(Context context, final Callable<T> task) {
|
| /external/v8/src/compiler/ |
| js-generic-lowering.h | 39 void ReplaceWithStubCall(Node* node, Callable c, CallDescriptor::Flags flags);
40 void ReplaceWithStubCall(Node* node, Callable c, CallDescriptor::Flags flags,
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/reflection/ |
| Callable.java | 20 public class Callable {
45 public Callable(Type type, String name, String setterName, ModelClass resolvedType,
82 return "Callable{" +
|
| /external/guice/extensions/servlet/src/com/google/inject/servlet/ |
| ServletScopes.java | 32 import java.util.concurrent.Callable;
183 * Wraps the given callable in a contextual callable that "continues" the
199 * <p>The returned callable will throw a {@link ScopingException} when called
202 * @param callable code to be executed in another thread, which depends on
207 * @return a callable that will invoke the given callable, making the request
214 public static <T> Callable<T> continueRequest(final Callable<T> callable,
[all...] |
