| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ExecutorCompletionServiceTest.java | 14 import java.util.concurrent.Callable;
61 * Submitting a null callable throws NPE
67 Callable c = null;
97 Callable c = new StringTask();
111 Callable c = new StringTask();
126 Callable c = new StringTask();
149 Callable c = new StringTask();
158 * Submitting to underlying AES that overrides newTaskFor(Callable)
164 MyCallableFuture(Callable<V> c) { super(c); }
171 protected <T> RunnableFuture<T> newTaskFor(Callable<T> c)
[all...] |
| ScheduledExecutorSubclassTest.java | 17 import java.util.concurrent.Callable;
88 protected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> c, RunnableScheduledFuture<V> task) {
121 * delayed schedule of callable successfully executes after delay
128 Callable task = new CheckedCallable<Boolean>() {
304 TrackedCallable callable = null; local
305 Future f = p.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
344 * schedule callable throws RejectedExecutionException if shutdown
[all...] |
| ScheduledExecutorTest.java | 19 import java.util.concurrent.Callable;
64 * delayed schedule of callable successfully executes after delay
71 Callable task = new CheckedCallable<Boolean>() {
248 TrackedCallable callable = null; local
249 Future f = p.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
288 * schedule callable throws RejectedExecutionException if shutdown
[all...] |
| /external/guava/guava/src/com/google/common/cache/ |
| Cache.java | 26 import java.util.concurrent.Callable;
34 * {@link #get(Object, Callable)} or {@link #put(Object, Object)}, and are stored in the cache until
77 V get(K key, Callable<? extends V> valueLoader) throws ExecutionException;
91 * <p>Prefer {@link #get(Object, Callable)} when using the conventional "if cached, return;
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| WrappingScheduledExecutorService.java | 18 import java.util.concurrent.Callable;
25 * {@linkplain #wrapTask(Callable) wrap} tasks before they are submitted to the underlying executor.
46 public final <V> ScheduledFuture<V> schedule(Callable<V> task, long delay, TimeUnit unit) {
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| FuturesCombineBenchmark.java | 26 import java.util.concurrent.Callable;
39 @Override <V> ListenableFuture<V> combine(final Callable<V> combiner, Executor executor,
59 <V> ListenableFuture<V> combine(Callable<V> combiner, final Executor executor,
66 Callable<V> combiner, Executor executor,
86 Callable<Integer> callable = Callables.returning(12);
89 sum += impl.combine(callable, INLINE_EXECUTOR, futures).get();
101 Callable<Integer> callable = Callables.returning(12);
104 sum += impl.combine(callable, INLINE_EXECUTOR, futures).get()
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| AbstractListeningExecutorServiceTest.java | 24 import java.util.concurrent.Callable;
70 private static class TestCallable implements Callable<String> {
|
| SimpleTimeLimiterTest.java | 21 import java.util.concurrent.Callable;
61 new Callable<String>() {
75 new Callable<String>() {
91 new Callable<String>() {
107 new Callable<String>() {
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/perf/targets/ |
| Target01.java | 14 import java.util.concurrent.Callable;
19 public class Target01 implements Callable<Void> {
|
| /external/mockito/src/test/java/org/mockitousage/bugs/ |
| ConcurrentModificationExceptionOnMultiThreadedVerificationTest.java | 11 import java.util.concurrent.Callable;
61 public class TargetInvoker implements Callable<Object> {
|
| /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/tests/src/androidx/media/filterfw/ |
| MffTestCase.java | 24 import java.util.concurrent.Callable;
43 FutureTask<MffContext> task = new FutureTask<MffContext>(new Callable<MffContext>() {
|
| /libcore/luni/src/test/java/sun/misc/ |
| UnsafeTest.java | 22 import java.util.concurrent.Callable;
40 Callable<Object> callable = Executors.callable(new Runnable() { local
47 callable.call();
|
| /external/guava/guava-testlib/test/com/google/common/testing/ |
| FakeTickerTest.java | 25 import java.util.concurrent.Callable;
110 new Callable<Void>() {
133 new Callable<Void>() {
145 * Runs {@code callable} concurrently {@code numberOfThreads} times.
148 private void runConcurrentTest(int numberOfThreads, final Callable<Void> callable)
154 executorService.submit(new Callable<Void>() {
159 callable.call();
|
| /external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
| MockServerSocketTest.java | 23 import java.util.concurrent.Callable;
84 final Future<Socket> f = executor.submit(new Callable<Socket>() {
100 final Future<Socket> f = executor.submit(new Callable<Socket>() {
121 final Future<Socket> f = executor.submit(new Callable<Socket>() {
137 final Future<Void> f = executor.submit(new Callable<Void>() {
|
| /packages/apps/Contacts/tests/src/com/android/contacts/test/ |
| IntegrationTestUtils.java | 33 import java.util.concurrent.Callable;
58 runOnUiThreadAndGetTheResult(new Callable<Void>() {
73 return runOnUiThreadAndGetTheResult(new Callable<CharSequence>() {
84 * Execute a callable on the ui thread, returning its result synchronously.
87 * before executing this callable.
89 public <T> T runOnUiThreadAndGetTheResult(Callable<T> callable) throws Throwable {
90 FutureTask<T> future = new FutureTask<T>(callable);
148 return runOnUiThreadAndGetTheResult(new Callable<List<TextView>>() {
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| SameThreadScheduledExecutorService.java | 31 import java.util.concurrent.Callable;
81 public <T> ListenableFuture<T> submit(Callable<T> task) {
101 Collection<? extends Callable<T>> tasks) throws InterruptedException {
108 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
116 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
123 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
142 return schedule(java.util.concurrent.Executors.callable(command),
176 public <V> ListenableScheduledFuture<V> schedule(final Callable<V> callable,
178 Preconditions.checkNotNull(callable, "callable must not be null!")
[all...] |
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/runtime/ |
| RuntimeDataTest.java | 20 import java.util.concurrent.Callable;
117 new String[] { Type.getInternalName(Callable.class) });
141 Callable<?> callable = (Callable<?>) loader.add("Sample", local
143 final Object[] args = (Object[]) callable.call();
158 new String[] { Type.getInternalName(Callable.class) });
192 Callable<?> callable = (Callable<?>) loade local
[all...] |
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/expr/ |
| MethodCallExpr.java | 20 import android.databinding.tool.reflection.Callable;
21 import android.databinding.tool.reflection.Callable.Type;
33 import static android.databinding.tool.reflection.Callable.DYNAMIC;
34 import static android.databinding.tool.reflection.Callable.STATIC;
39 Callable mGetter;
164 mGetter = new Callable(Type.METHOD, method.getName(), null, method.getReturnType(args),
199 public Callable getGetter() {
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| TestScheduledExecutorService.java | 30 import java.util.concurrent.Callable;
76 public <T> Future<T> submit(Callable<T> task) {
91 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
97 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout,
103 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
109 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
127 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
|
| /external/conscrypt/testing/src/main/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 19 import java.util.concurrent.Callable;
69 Future<Void> s = executor.submit(new Callable<Void>() {
79 Future<Void> c = executor.submit(new Callable<Void>() {
|
| /external/dagger2/core/src/test/java/dagger/internal/ |
| DoubleCheckLazyTest.java | 24 import java.util.concurrent.Callable;
49 List<Callable<Object>> tasks = Lists.newArrayListWithCapacity(numThreads);
51 tasks.add(new Callable<Object>() {
|
| /external/droiddriver/src/io/appium/droiddriver/instrumentation/ |
| InstrumentationDriver.java | 32 import java.util.concurrent.Callable;
36 private static final Callable<View> FIND_ROOT_VIEW =
37 new Callable<View>() {
|
| /external/guice/core/test/com/google/inject/internal/ |
| CycleDetectingLockTest.java | 7 import java.util.concurrent.Callable;
73 new Callable<Void>() {
85 new Callable<Void>() {
|
| /external/libchrome/base/ |
| bind_internal.h | 62 template <typename Callable,
63 typename Signature = decltype(&Callable::operator())>
66 template <typename Callable, typename R, typename... Args>
67 struct ExtractCallableRunTypeImpl<Callable, R(Callable::*)(Args...) const> {
71 // Evaluated to RunType of the given callable type.
77 template <typename Callable>
79 typename ExtractCallableRunTypeImpl<Callable>::Type;
99 template <typename Callable>
100 struct IsConvertibleToRunType<Callable, void_t<decltype(&Callable::operator())>
[all...] |
| /external/testng/src/main/java/org/testng/internal/thread/ |
| ThreadUtil.java | 7 import java.util.concurrent.Callable;
58 List<Callable<Object>> callables = Lists.newArrayList();
60 callables.add(new Callable<Object>() {
|
