| /cts/tests/tests/net/src/android/net/wifi/cts/ |
| WifiInfoTest.java | 31 import java.util.concurrent.Callable;
140 PollingCheck.check("getNetworkId not -1", 20000, new Callable<Boolean>() {
148 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/org/junit/internal/runners/ |
| MethodRoadie.java | 6 import java.util.concurrent.Callable;
60 Callable<Object> callable= new Callable<Object>() {
66 Future<Object> result= service.submit(callable);
|
| /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);
|
| /libcore/support/src/test/java/tests/support/ |
| Support_Exec.java | 30 import java.util.concurrent.Callable;
139 private static Callable<String> streamToStringCallable(final InputStream in) {
140 return new Callable<String>() {
|
| /packages/apps/Messaging/src/android/support/v7/mms/ |
| SendRequest.java | 33 import java.util.concurrent.Callable;
103 final Callable<byte[]> copyPduToArray = new Callable<byte[]>() {
|
| /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>() {
|
| MoreExecutorsTest.java | 61 import java.util.concurrent.Callable;
145 final Callable<Integer> incrementTask = new Callable<Integer>() {
180 Future<?> future = executor.submit(new Callable<Void>() {
264 List<Callable<T>> tasks = ImmutableList.of();
273 List<Callable<String>> callables =
435 invokeAnyImpl(e, new ArrayList<Callable<String>>(), false, 0);
448 List<Callable<Integer>> l = new ArrayList<Callable<Integer>>();
449 l.add(new Callable<Integer>()
[all...] |
| /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/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/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/luni/src/main/java/java/util/concurrent/ |
| ExecutorCompletionService.java | 28 * Collection<Callable<Result>> solvers)
32 * for (Callable<Result> s : solvers)
48 * Collection<Callable<Result>> solvers)
56 * for (Callable<Result> s : solvers)
97 private RunnableFuture<V> newTaskFor(Callable<V> task) {
151 public Future<V> submit(Callable<V> task) {
|
| FutureTask.java | 22 * <p>A {@code FutureTask} can be used to wrap a {@link Callable} or
73 /** The underlying callable; nulled out after running */
74 private Callable<V> callable; field in class:FutureTask
77 /** The thread running the callable; CASed during run() */
99 * given {@code Callable}.
101 * @param callable the callable task
102 * @throws NullPointerException if the callable is null
104 public FutureTask(Callable<V> callable)
[all...] |
| /external/guava/guava-tests/test/com/google/common/base/ |
| FinalizableReferenceQueueClassLoaderUnloadingTest.java | 32 import java.util.concurrent.Callable;
163 public static class FrqUser implements Callable<WeakReference<Object>> {
224 Callable<?> sepFrqUser = (Callable<?>) sepFrqUserC.newInstance();
|
| /external/guice/extensions/servlet/test/com/google/inject/servlet/ |
| ContinuingRequestIntegrationTest.java | 39 import java.util.concurrent.Callable;
87 @Override public <T> Future<T> submit(Callable<T> task) {
200 @Inject OffRequestCallable callable; field in class:ContinuingRequestIntegrationTest.ContinuingServlet
211 Callable<String> task = ServletScopes.continueRequest(callable,
219 public static class OffRequestCallable implements Callable<String> {
|
| ScopeRequestIntegrationTest.java | 36 import java.util.concurrent.Callable;
118 Callable<SomeObject> callable = injector.getInstance(Caller.class); local
120 assertNotNull(callable.call());
129 callable = ServletScopes.scopeRequest(injector.getInstance(Caller.class), map);
130 assertNull(callable.call());
145 public static class OffRequestCallable implements Callable<String> {
161 private static class Caller implements Callable<SomeObject> {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| MoreExecutors.java | 36 import java.util.concurrent.Callable;
575 Callable<V> callable, long delay, TimeUnit unit) {
576 ListenableFutureTask<V> task = ListenableFutureTask.create(callable);
673 Collection<? extends Callable<T>> tasks, boolean timed, long nanos)
692 Iterator<? extends Callable<T>> it = tasks.iterator();
746 ListeningExecutorService executorService, Callable<T> task,
[all...] |
| /libcore/luni/src/test/java/libcore/javax/net/ssl/ |
| SSLSocketTest.java | 44 import java.util.concurrent.Callable;
350 Future<Void> future = executor.submit(new Callable<Void>() {
388 private static final class SSLServerSessionIdCallable implements Callable<byte[]> {
445 Future<Void> future = executor.submit(new Callable<Void>() {
475 Future<Void> future = executor.submit(new Callable<Void>() {
505 Future<Void> future = executor.submit(new Callable<Void>() {
525 Future<Void> future = executor.submit(new Callable<Void>() {
648 Future<Void> future = executor.submit(new Callable<Void>() {
714 Future<IOException> future = executor.submit(new Callable<IOException>() {
[all...] |
| /external/llvm/include/llvm/ADT/ |
| STLExtras.h | 60 /// An efficient, type-erasing, non-owning reference to a callable. This is
64 /// This class does not own the callable, so it is not in general safe to store
70 Ret (*callback)(intptr_t callable, Params ...params);
71 intptr_t callable; member in class:llvm::function_ref
73 template<typename Callable>
74 static Ret callback_fn(intptr_t callable, Params ...params) {
75 return (*reinterpret_cast<Callable*>(callable))(
80 template <typename Callable>
81 function_ref(Callable &&callable
[all...] |
