| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/expr/ |
| MethodCallExpr.java | 19 import static android.databinding.tool.reflection.Callable.DYNAMIC;
20 import static android.databinding.tool.reflection.Callable.STATIC;
23 import android.databinding.tool.reflection.Callable;
24 import android.databinding.tool.reflection.Callable.Type;
38 Callable mGetter;
117 mGetter = new Callable(Type.METHOD, method.getName(), null, method.getReturnType(args),
152 public Callable getGetter() {
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ForkJoinPoolTest.java | 17 import java.util.concurrent.Callable;
443 * Completed submit(callable) returns result
485 final Callable callable = Executors.callable(new PrivilegedAction() { local
491 Future future = e.submit(callable);
503 final Callable callable = local
504 Executors.callable(new PrivilegedExceptionAction() {
510 Future future = e.submit(callable);
522 final Callable callable = local
[all...] |
| 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...] |
| /external/guice/core/test/com/google/inject/ |
| PerformanceComparison.java | 31 import java.util.concurrent.Callable;
69 static final Callable<Foo> springFactory = new Callable<Foo>() {
106 static final Callable<Foo> juiceFactory = new Callable<Foo>() {
131 static final Callable<Foo> byHandFactory = new Callable<Foo>() {
145 static void validate(Callable<Foo> t) throws Exception {
156 static void iterate(Callable<Foo> callable, String label)
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 36 * protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
68 * Returns a {@code RunnableFuture} for the given callable task.
70 * @param callable the callable task being wrapped
71 * @param <T> the type of the callable's result
73 * underlying callable and which, as a {@code Future}, will yield
74 * the callable's result as its result and provide for
78 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
79 return new FutureTask<T>(callable);
[all...] |
| /external/guice/jdk8-tests/test/com/google/inject/jdk8/ |
| Java8LanguageFeatureBindingTest.java | 34 import java.util.concurrent.Callable;
67 public Callable<String> provideCallable() {
72 Callable<String> callable = injector.getInstance(new Key<Callable<String>>() {}); local
73 assertEquals("foo", callable.call());
82 public Callable<String> provideCallable() {
92 injector.getInstance(new Key<Callable<String>>() {});
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/shadows/ |
| ProgressDialogTest.java | 13 import java.util.concurrent.Callable;
80 assertLatestDialogsSet("Title", "Message", false, false, null, new Callable<ProgressDialog>() {
91 assertLatestDialogsSet("Title", "Message", true, false, null, new Callable<ProgressDialog>() {
101 assertLatestDialogsSet("Title", "Message", true, true, null, new Callable<ProgressDialog>() {
117 assertLatestDialogsSet("Title", "Message", true, true, cancelListener, new Callable<ProgressDialog>() {
127 Callable<ProgressDialog> callable) throws Exception {
131 dialog = callable.call();
|
| /art/test/523-checker-can-throw-regression/src/ |
| Main.java | 21 import java.util.concurrent.Callable;
|
| /cts/tests/app/src/android/app/cts/ |
| IntentServiceTest.java | 28 import java.util.concurrent.Callable;
63 new Callable<Boolean>() {
70 PollingCheck.check("accumulator not correct", TIMEOUT_MSEC, new Callable<Boolean>() {
77 PollingCheck.check("onDestroyCalled not called", TIMEOUT_MSEC, new Callable<Boolean>() {
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| AbstractExecutorService.java | 31 public <T> Future<T> submit(Callable<T> task) {
38 private <T> T doInvokeAny(Collection<? extends Callable<T>> tasks,
53 Iterator<? extends Callable<T>> it = tasks.iterator();
104 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
127 for (Callable<T> t : tasks) {
150 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
159 for (Callable<T> t : tasks)
|
| /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> {
|
| /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();
|
| /cts/tests/tests/webkit/src/android/webkit/cts/ |
| ServiceWorkerClientTest.java | 35 import java.util.concurrent.Callable;
146 Callable<Boolean> registrationSuccess = new Callable<Boolean>() {
155 Callable<Boolean> receivedRequest = new Callable<Boolean>() {
|
| /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>() {
|
| 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>() {
|
| /packages/apps/ContactsCommon/TestCommon/src/com/android/contacts/common/test/ |
| IntegrationTestUtils.java | 37 import java.util.concurrent.Callable;
62 runOnUiThreadAndGetTheResult(new Callable<Void>() {
77 return runOnUiThreadAndGetTheResult(new Callable<CharSequence>() {
88 * Execute a callable on the ui thread, returning its result synchronously.
91 * before executing this callable.
93 public <T> T runOnUiThreadAndGetTheResult(Callable<T> callable) throws Throwable {
94 FutureTask<T> future = new FutureTask<T>(callable);
152 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...] |
