| /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> {
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| 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/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| 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/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/guava/guava-tests/test/com/google/common/util/concurrent/ |
| 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...] |
| JSR166TestCase.java | 867 public abstract class CheckedCallable<T> implements Callable<T> {
881 implements Callable<T> {
902 public static class NoOpCallable implements Callable {
908 public static class StringTask implements Callable<String> {
912 public Callable<String> latchAwaitingStringTask(final CountDownLatch latch) {
[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> {
|
| /external/guava/guava/src/com/google/common/cache/ |
| AbstractCache.java | 25 import java.util.concurrent.Callable;
54 public V get(K key, Callable<? extends V> valueLoader) throws ExecutionException {
|
| CacheLoader.java | 32 import java.util.concurrent.Callable;
194 ListenableFutureTask<V> task = ListenableFutureTask.create(new Callable<V>() {
|
| /external/guava/guava-tests/test/com/google/common/collect/ |
| ConcurrentHashMultisetBasherTest.java | 26 import java.util.concurrent.Callable;
102 private static class MutateTask implements Callable<int[]> {
|
| /external/jacoco/org.jacoco.agent.rt/src/org/jacoco/agent/rt/internal/ |
| Agent.java | 17 import java.util.concurrent.Callable;
85 private Callable<Void> jmxRegistration;
|
| /external/testng/src/main/java/org/testng/internal/ |
| TestMethodWithDataProviderMethodWorker.java | 12 import java.util.concurrent.Callable;
14 public class TestMethodWithDataProviderMethodWorker implements Callable<List<ITestResult>> {
|
| /frameworks/base/packages/MtpDocumentsProvider/tests/src/com/android/mtp/ |
| MtpManagerTest.java | 33 import java.util.concurrent.Callable;
64 new Callable<Boolean>() {
|
| /frameworks/support/room/compiler/src/main/kotlin/android/arch/persistence/room/solver/query/result/ |
| FlowableQueryResultBinder.kt | 44 superclass(ParameterizedTypeName.get(java.util.concurrent.Callable::class.typeName(),
|
| /frameworks/support/room/rxjava2/src/main/java/android/arch/persistence/room/ |
| RxRoom.java | 24 import java.util.concurrent.Callable;
99 * Helper method used by generated code to bind a Callable such that it will be run in
106 final String[] tableNames, final Callable<T> callable) {
111 T data = callable.call();
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/ |
| OutputStreamTesterTest.java | 40 import java.util.concurrent.Callable;
124 future = executor.submit(new Callable<byte[]>() {
|
| WriterTesterTest.java | 39 import java.util.concurrent.Callable;
117 future = executor.submit(new Callable<char[]>() {
|
| /libcore/luni/src/test/java/libcore/java/lang/reflect/parameter/ |
| ParameterMetadataTestClasses$-java_lang_Class_getLambdaClassWith1ParameterConstructor__LambdaImpl0.smali | 23 .implements Ljava/util/concurrent/Callable;
|
| /libcore/luni/src/test/java/libcore/java/util/zip/ |
| DeflaterOutputStreamTest.java | 28 import java.util.concurrent.Callable;
80 executor.submit(new Callable<Void>() {
|
| /packages/apps/Launcher3/src/com/android/launcher3/ |
| LauncherAppState.java | 38 import java.util.concurrent.Callable;
63 return new MainThreadExecutor().submit(new Callable<LauncherAppState>() {
|
