| /packages/apps/Contacts/src/com/android/contacts/util/concurrent/ |
| ContactsExecutors.java | 17 import java.util.concurrent.Callable;
120 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
121 final HandlerFuture<V> future = new HandlerFuture<>(mHandler, delay, unit, callable);
175 private final Callable<T> mTask;
180 private HandlerFuture(Handler handler, long delay, TimeUnit timeUnit, Callable<T> task) {
233 return new HandlerFuture<>(handler, delay, unit, new Callable<Void>() {
|
| /cts/tests/tests/net/src/android/net/wifi/cts/ |
| WifiInfoTest.java | 33 import java.util.concurrent.Callable;
142 PollingCheck.check("getNetworkId not -1", 20000, new Callable<Boolean>() {
150 PollingCheck.check("getWifiState not disabled", 20000, new Callable<Boolean>() {
|
| /external/guice/extensions/servlet/src/com/google/inject/servlet/ |
| GuiceFilter.java | 27 import java.util.concurrent.Callable;
130 new Context(originalRequest, request, response).call(new Callable<Void>() {
199 synchronized <T> T call(Callable<T> callable) throws Exception {
203 return callable.call();
|
| /external/junit/src/main/java/org/junit/internal/runners/ |
| MethodRoadie.java | 6 import java.util.concurrent.Callable;
62 Callable<Object> callable = new Callable<Object>() {
68 Future<Object> result = service.submit(callable);
|
| /external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| InterceptedInvocation.java | 22 import java.util.concurrent.Callable;
181 private final Callable<?> callable; field in class:InterceptedInvocation.SuperMethod.FromCallable
183 public FromCallable(Callable<?> callable) {
184 this.callable = callable;
195 return callable.call();
|
| MockMethodInterceptor.java | 19 import java.util.concurrent.Callable;
98 @SuperCall(serializableProxy = true) Callable<?> superCall) throws Throwable {
|
| /frameworks/data-binding/compiler/src/test/java/android/databinding/tool/ |
| LayoutBinderTest.java | 22 import android.databinding.tool.reflection.Callable;
103 final Callable getter = fa.getGetter();
104 assertTrue(getter.type == Callable.Type.METHOD);
|
| /frameworks/support/compat/java/android/support/v4/provider/ |
| SelfDestructiveThread.java | 29 import java.util.concurrent.Callable;
131 * Execute the specific callable object on this thread and call the reply callback on the
134 public <T> void postAndReply(final Callable<T> callable, final ReplyCallback<T> reply) {
141 t = callable.call();
157 * Execute the specified callable object on this thread and returns the returned value to the
163 public <T> T postAndWait(final Callable<T> callable, int timeoutMillis)
174 holder.set(callable.call());
|
| /frameworks/support/room/runtime/src/test/java/android/arch/persistence/room/ |
| SharedSQLiteStatementTest.java | 36 import java.util.concurrent.Callable;
96 new Callable<SupportSQLiteStatement>() {
115 new Callable<SupportSQLiteStatement>() {
|
| /packages/apps/Messaging/src/android/support/v7/mms/ |
| SendRequest.java | 33 import java.util.concurrent.Callable;
103 final Callable<byte[]> copyPduToArray = new Callable<byte[]>() {
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/expr/ |
| FieldAccessExpr.java | 25 import android.databinding.tool.reflection.Callable;
26 import android.databinding.tool.reflection.Callable.Type;
43 Callable mGetter;
52 public Callable getGetter() {
284 if (getGetter().type == Callable.Type.FIELD) {
296 if (getGetter().type == Callable.Type.FIELD) {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| StreamService.java | 47 import java.util.concurrent.Callable;
245 final ListenableFuture<Integer> processFuture = streamExecutor.submit(new Callable<Integer>() {
253 streamExecutor.submit(new Callable<Void>() {
334 /** Returns a callable that renames the the thread that the given callable runs in. */
335 private static <T> Callable<T> threadRenaming(final String name, final Callable<T> callable) {
337 checkNotNull(callable);
338 return new Callable<T>()
[all...] |
| /external/guava/guava/src/com/google/common/cache/ |
| ForwardingCache.java | 25 import java.util.concurrent.Callable;
61 public V get(K key, Callable<? extends V> valueLoader) throws ExecutionException {
|
| AbstractLoadingCache.java | 25 import java.util.concurrent.Callable;
34 * {@link #getUnchecked}, {@link #get(Object, Callable)}, and {@link #getAll} are implemented in
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| TestingExecutors.java | 29 import java.util.concurrent.Callable;
131 Callable<V> callable, long delay, TimeUnit unit) {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ListenableFutureTaskTest.java | 23 import java.util.concurrent.Callable;
46 ListenableFutureTask.create(new Callable<Integer>() {
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| CompositeService.java | 28 import java.util.concurrent.Callable;
106 return new FutureTask<Service.State>(new Callable<Service.State>() {
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/perf/targets/ |
| Target03.java | 15 import java.util.concurrent.Callable;
23 public class Target03 implements Callable<Void> {
|
| /external/jsoncpp/scons-tools/ |
| substinfile.py | 14 If a value of SUBST_DICT is a python callable function, it is called and
45 if isinstance(v, collections.Callable):
50 raise SCons.Errors.UserError("SubstInFile: key %s: %s must be a string or callable"%(k, repr(v)))
65 if isinstance(v, collections.Callable):
|
| /external/junit/src/main/java/org/junit/internal/runners/statements/ |
| FailOnTimeout.java | 3 import java.util.concurrent.Callable;
98 CallableStatement callable = new CallableStatement(); local
99 FutureTask<Throwable> task = new FutureTask<Throwable>(callable);
103 callable.awaitStarted();
142 private class CallableStatement implements Callable<Throwable> {
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/ |
| ShadowAsyncTask.java | 10 import java.util.concurrent.Callable;
116 private final class BackgroundWorker implements Callable<Result> {
|
| /external/v8/src/compiler/ |
| js-intrinsic-lowering.h | 17 class Callable;
85 Reduction Change(Node* node, Callable const& callable,
|
| /external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
| ThreadUtils.java | 33 import java.util.concurrent.Callable;
157 * Post |callable| to |handler| and wait for the result.
159 public static <V> V invokeUninterruptibly(final Handler handler, final Callable<V> callable) {
168 result.value = callable.call();
170 throw new RuntimeException("Callable threw exception: " + e);
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| ExecutorCompletionService.java | 57 * Collection<Callable<Result>> solvers)
61 * for (Callable<Result> s : solvers)
77 * Collection<Callable<Result>> solvers)
85 * for (Callable<Result> s : solvers)
126 private RunnableFuture<V> newTaskFor(Callable<V> task) {
180 public Future<V> submit(Callable<V> task) {
|
| /art/test/708-jit-cache-churn/src/ |
| JitCacheChurnTest.java | 22 import java.util.concurrent.Callable;
71 private void runTasks(Callable<Integer> task) {
77 ArrayList<Callable<Integer>> tasks = new ArrayList<>(CONCURRENCY);
92 private static abstract class BaseTask implements Callable<Integer> {
|
