| /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/guava/guava-tests/test/com/google/common/util/concurrent/ |
| 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.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>() {
|
| TcpConnectionTest.java | 21 import java.util.concurrent.Callable;
90 final Future<Void> f = executor.submit(new Callable<Void>() {
110 final Future<Void> f = executor.submit(new Callable<Void>() {
138 final Future<Void> f = executor.submit(new Callable<Void>() {
163 final Future<Void> f = executor.submit(new Callable<Void>() {
190 final Future<Void> f = executor.submit(new Callable<Void>() {
246 final Future<Void> f = executor.submit(new Callable<Void>() {
|
| MockSocketConnectionTest.java | 24 import java.util.concurrent.Callable;
96 final Future<Void> f = executor.submit(new Callable<Void>() {
154 final Future<Byte> f = executor.submit(new Callable<Byte>() {
176 final Future<Byte> f = executor.submit(new Callable<Byte>() {
|
| /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>>() {
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| 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...] |
| ExecutorsTest.java | 20 import java.util.concurrent.Callable;
211 Future f = p.schedule(Executors.callable(task, Boolean.TRUE),
235 Future f = p.schedule(Executors.callable(task, Boolean.TRUE),
261 Future f = p.schedule(Executors.callable(task, Boolean.TRUE),
400 class CheckCCL implements Callable<Object> {
453 Callable task = Executors.privilegedCallable(new CheckCCL());
471 // final Callable[] task = new Callable[1];
529 * callable(Runnable) returns null when called
532 Callable c = Executors.callable(new NoOpRunnable())
[all...] |
| /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/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>() {
|
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 19 import java.util.concurrent.Callable;
80 Future s = executor.submit(new Callable<Void>() {
89 Future c = executor.submit(new Callable<Void>() {
|
| /libcore/support/src/test/java/tests/support/ |
| Support_Exec.java | 30 import java.util.concurrent.Callable;
117 private static Callable<String> streamToStringCallable(final InputStream in) {
118 return new Callable<String>() {
|
| /packages/apps/Messaging/src/android/support/v7/mms/ |
| DownloadRequest.java | 32 import java.util.concurrent.Callable;
84 final Callable<Boolean> copyDownloadedPduToOutput = new Callable<Boolean>() {
|
| /external/droiddriver/src/io/appium/droiddriver/util/ |
| InstrumentationUtils.java | 27 import java.util.concurrent.Callable;
125 new Callable<Void>() {
135 * Runs {@code callable} on the main thread on best-effort basis up to a time limit, which
141 * am command line.The {@code callable} may never run, for example, if the main Looper has exited
144 public static <V> V runOnMainSyncWithTimeout(Callable<V> callable) {
146 final RunOnMainSyncFutureTask<V> futureTask = new RunOnMainSyncFutureTask<>(callable);
189 public RunOnMainSyncFutureTask(Callable<V> callable) {
190 super(callable);
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| SimpleTimeLimiter.java | 31 import java.util.concurrent.Callable;
100 Callable<Object> callable = new Callable<Object>() {
111 return callWithTimeout(callable, timeoutDuration, timeoutUnit,
120 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
122 checkNotNull(callable);
126 Future<T> future = executor.submit(callable);
|
| /frameworks/data-binding/compiler/src/main/kotlin/android/databinding/tool/expr/ |
| ExprWriters.kt | 19 import android.databinding.tool.reflection.Callable
44 val eligible = localize || (myExpr is MethodCallExpr || (myExpr is FieldAccessExpr && myExpr.getter.type == Callable.Type.METHOD))
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/reflection/ |
| ModelClass.java | 18 import android.databinding.tool.reflection.Callable.Type;
28 import static android.databinding.tool.reflection.Callable.CAN_BE_INVALIDATED;
29 import static android.databinding.tool.reflection.Callable.DYNAMIC;
30 import static android.databinding.tool.reflection.Callable.STATIC;
394 public Callable findGetterOrField(String name, boolean staticOnly) {
396 return new Callable(Type.FIELD, name, null,
428 final Callable result = new Callable(Callable.Type.METHOD, methodName,
464 return new Callable(Callable.Type.FIELD, name, setterFieldName, fieldType, 0, flags, null)
[all...] |
