| /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/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/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| MockMethodInterceptor.java | 19 import java.util.concurrent.Callable;
98 @SuperCall(serializableProxy = true) Callable<?> superCall) throws Throwable {
|
| MockMethodAdvice.java | 24 import java.util.concurrent.Callable;
43 private static Callable<?> enter(@Identifier String identifier,
58 @Advice.Enter Callable<?> mocked) throws Throwable {
65 public Callable<?> handle(Object instance, Method origin, Object[] arguments) throws Throwable {
185 private static class ReturnValueWrapper implements Callable<Object> {
|
| /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;
68 Reduction Change(Node* node, Callable const& callable,
|
| js-generic-lowering.cc | 54 Callable callable = CodeFactory::Name(isolate()); \
55 ReplaceWithStubCall(node, callable, flags); \
83 void JSGenericLowering::ReplaceWithStubCall(Node* node, Callable callable,
85 ReplaceWithStubCall(node, callable, flags, node->op()->properties());
88 void JSGenericLowering::ReplaceWithStubCall(Node* node, Callable callable,
91 const CallInterfaceDescriptor& descriptor = callable.descriptor();
95 Node* stub_code = jsgraph()->HeapConstant(callable.code())
121 Callable callable = CodeFactory::StrictEqual(isolate()); local
130 Callable callable = CodeFactory::StrictNotEqual(isolate()); local
139 Callable callable = CodeFactory::ToBoolean(isolate()); local
148 Callable callable = CodeFactory::Typeof(isolate()); local
161 Callable callable = CodeFactory::KeyedLoadICInOptimizedCode(isolate()); local
185 Callable callable = CodeFactory::LoadICInOptimizedCode(isolate()); local
210 Callable callable = local
239 Callable callable = local
272 Callable callable = local
305 Callable callable = local
350 Callable callable = CodeFactory::InstanceOf(isolate()); local
356 Callable callable = CodeFactory::OrdinaryHasInstance(isolate()); local
400 Callable callable = CodeFactory::FastNewObject(isolate()); local
443 Callable callable = CodeFactory::FastNewClosure(isolate()); local
458 Callable callable = CodeFactory::FastNewFunctionContext(isolate()); local
485 Callable callable = CodeFactory::FastCloneShallowArray(isolate()); local
505 Callable callable = local
517 Callable callable = CodeFactory::FastCloneRegExp(isolate()); local
562 Callable callable = CodeFactory::Construct(isolate()); local
582 Callable callable = CodeFactory::Call(isolate(), mode); local
[all...] |
| code-assembler.h | 24 class Callable;
355 Node* CallStub(Callable const& callable, Node* context, Node* arg1,
357 Node* CallStub(Callable const& callable, Node* context, Node* arg1,
359 Node* CallStub(Callable const& callable, Node* context, Node* arg1,
361 Node* CallStub(Callable const& callable, Node* context, Node* arg1,
363 Node* CallStubN(Callable const& callable, Node** args
[all...] |
| /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) {
|
| FutureTask.java | 51 * <p>A {@code FutureTask} can be used to wrap a {@link Callable} or
102 /** The underlying callable; nulled out after running */
103 private Callable<V> callable; field in class:FutureTask
106 /** The thread running the callable; CASed during run() */
128 * given {@code Callable}.
130 * @param callable the callable task
131 * @throws NullPointerException if the callable is null
133 public FutureTask(Callable<V> callable)
[all...] |
| /external/guava/guava/src/com/google/common/cache/ |
| AbstractLoadingCache.java | 25 import java.util.concurrent.Callable;
34 * {@link #getUnchecked}, {@link #get(Object, Callable)}, and {@link #getAll} are implemented in
|
| AbstractCache.java | 25 import java.util.concurrent.Callable;
54 public V get(K key, Callable<? extends V> valueLoader) throws ExecutionException {
|
| /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...] |
| /external/llvm/include/llvm/ADT/ |
| STLExtras.h | 62 /// An efficient, type-erasing, non-owning reference to a callable. This is
66 /// This class does not own the callable, so it is not in general safe to store
72 Ret (*callback)(intptr_t callable, Params ...params);
73 intptr_t callable; member in class:llvm::function_ref
75 template<typename Callable>
76 static Ret callback_fn(intptr_t callable, Params ...params) {
77 return (*reinterpret_cast<Callable*>(callable))(
82 template <typename Callable>
83 function_ref(Callable &&callable
[all...] |
| /external/dexmaker/dexmaker-tests/src/androidTest/java/com/android/dx/stock/ |
| ProxyBuilderTest.java | 34 import java.util.concurrent.Callable;
732 ProxyBuilder.callSuper(declaresInterface, Callable.class.getMethod("call"));
738 public static abstract class DeclaresInterface implements Callable<String> {}
743 .implementing(Callable.class)
748 Callable<?> asCallable = (Callable<?>) simpleClass;
759 .implementing(Callable.class)
762 ProxyBuilder.callSuper(simpleClass, Callable.class.getMethod("call"));
778 .implementing(Callable.class)
803 Callable<?> proxy = proxyFor(ImplementsCallable.class
[all...] |
| /cts/tests/sensor/src/android/hardware/cts/helpers/sensoroperations/ |
| ParallelSensorOperation.java | 27 import java.util.concurrent.Callable;
98 Future<SensorOperation> future = executor.submit(new Callable<SensorOperation>() {
|
| /external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
| TrialRunLoop.java | 35 import java.util.concurrent.Callable;
47 @TrialScoped class TrialRunLoop implements Callable<TrialResult> {
|
