| /art/test/522-checker-regression-monitor-exit/src/ |
| Main.java | 21 import java.util.concurrent.Callable;
34 private static class HashCodeQuery implements Callable<Integer> {
|
| /external/droiddriver/src/io/appium/droiddriver/instrumentation/ |
| InstrumentationUiDevice.java | 27 import java.util.concurrent.Callable;
57 private static class GetScreenshot implements Callable<Bitmap> {
|
| /external/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| TypeCachingBytecodeGenerator.java | 12 import java.util.concurrent.Callable;
34 new Callable<Class<?>>() {
|
| 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();
|
| /external/mockito/src/test/java/org/mockitousage/serialization/ |
| ParallelSerializationTest.java | 36 // prepare all threads by submitting a callable
40 // submit a callable that will serialize the mock 'iMethods'
41 futures.add(executorService.submit(new Callable<Object>() {
51 // submit a callable that will only use the mock 'iMethods'
52 executorService.submit(new Callable<Object>() {
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorServiceTest.java | 9 import java.util.concurrent.Callable;
61 Future<String> future = executorService.submit(new Callable<String>() {
|
| /external/vogar/src/vogar/target/junit/ |
| TimeoutAndAbortRunRule.java | 19 import java.util.concurrent.Callable;
68 Future<Throwable> result = executor.submit(new Callable<Throwable>() {
|
| /libcore/luni/src/test/java/tests/security/ |
| SecureRandomTest.java | 21 import java.util.concurrent.Callable;
82 ecs.submit(new Callable<Void>() {
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| DeviceConcurrentUtil.java | 24 import java.util.concurrent.Callable;
76 * A {@link Callable} that wraps the details of executing shell command on
80 * output and determine return of the <code>Callable</code>
82 * @param <V> passthru of the {@link Callable} return type, see
83 * {@link Callable}
85 public static abstract class ShellCommandCallable<V> implements Callable<V> {
|
| /tools/tradefederation/core/util-apps/WifiUtil/src/com/android/tradefed/utils/wifi/ |
| WifiConnector.java | 36 import java.util.concurrent.Callable;
78 * @param checker a <code>Callable</code> to check the expected condition
79 * @param description a description of what this callable is doing
84 private long waitForCallable(final Callable<Boolean> checker, final String description,
104 throw new WifiException("failed to wait for callable", e);
110 private void waitForCallable(final Callable<Boolean> checker, final String description)
228 timeSpent = waitForCallable(new Callable<Boolean>() {
254 timeSpent = waitForCallable(new Callable<Boolean>() {
264 timeSpent = waitForCallable(new Callable<Boolean>() {
273 waitForCallable(new Callable<Boolean>()
[all...] |
| /cts/tests/tests/webkit/src/android/webkit/cts/ |
| GeolocationTest.java | 47 import java.util.concurrent.Callable;
336 Callable<Boolean> receivedRequest = new Callable<Boolean>() {
343 Callable<Boolean> receivedLocation = new Callable<Boolean>() {
430 Callable<Boolean> receivedRequest = new Callable<Boolean>() {
437 Callable<Boolean> receivedLocation = new Callable<Boolean>() {
551 Callable<Boolean> receivedRequest = new Callable<Boolean>()
[all...] |
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ThreadPoolExecutorSubclassTest.java | 18 import java.util.concurrent.Callable;
54 final Callable<V> callable; field in class:ThreadPoolExecutorSubclassTest.CustomTask
62 CustomTask(Callable<V> c) {
64 callable = c;
68 callable = new Callable<V>() {
102 v = callable.call();
153 protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
669 Callable task = new CheckedCallable<Boolean>()
[all...] |
| ThreadPoolExecutorTest.java | 19 import java.util.concurrent.Callable;
554 Callable task = new CheckedCallable<Boolean>() {
620 Callable task = new CheckedCallable<Boolean>() {
[all...] |
| /frameworks/data-binding/compiler/src/test/java/android/databinding/tool/ |
| ExpressionVisitorTest.java | 33 import android.databinding.tool.reflection.Callable;
150 Callable getter = parsed.getGetter();
151 assertEquals(Callable.Type.METHOD, getter.type);
166 Callable getter = parsed.getGetter();
167 assertEquals(Callable.Type.METHOD, getter.type);
|
| LayoutBinderTest.java | 22 import android.databinding.tool.reflection.Callable;
103 final Callable getter = fa.getGetter();
104 assertTrue(getter.type == Callable.Type.METHOD);
|
| /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);
|
| /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());
|
| /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 {
|
| /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) {
|
