| /external/mockito/src/test/java/org/mockitousage/configuration/ |
| ClassCacheVersusClassReloadingTest.java | 12 import java.util.concurrent.Callable;
29 public static class DoTheMocking implements Callable<Object> {
53 public static class PrepareMockito implements Callable<Boolean> {
|
| /external/testng/src/main/java/org/testng/internal/ |
| PoolService.java | 7 import java.util.concurrent.Callable;
40 public List<FutureType> submitTasksAndWait(List<? extends Callable<FutureType>> tasks) {
43 for (Callable<FutureType> callable : tasks) {
44 m_completionService.submit(callable);
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| TestingExecutorsTest.java | 26 import java.util.concurrent.Callable;
67 Callable<Boolean> task = new Callable<Boolean>() {
88 Callable<Integer> task = new Callable<Integer>() {
96 assertTrue("Should run callable immediately", taskDone);
|
| /frameworks/support/compat/tests/java/android/support/v4/provider/ |
| SelfDestructiveThreadTest.java | 36 import java.util.concurrent.Callable;
89 thread.postAndWait(new Callable<Object>() {
104 Integer generation = thread.postAndWait(new Callable<Integer>() {
112 Integer nextGeneration = thread.postAndWait(new Callable<Integer>() {
127 Integer generation = thread.postAndWait(new Callable<Integer>() {
134 Integer nextGeneration = thread.postAndWait(new Callable<Integer>() {
150 Integer generation = thread.postAndWait(new Callable<Integer>() {
161 Integer nextGeneration = thread.postAndWait(new Callable<Integer>() {
181 thread.postAndWait(new Callable<Object>() {
256 final Callable<Integer> callable = new Callable<Integer>() local
[all...] |
| /cts/hostsidetests/devicepolicy/app/DeviceAndProfileOwner/src/com/android/cts/deviceandprofileowner/ |
| AudioRestrictionTest.java | 26 import java.util.concurrent.Callable;
32 private final Callable<Boolean> mCheckIfMasterVolumeMuted = new Callable<Boolean>() {
105 waitUntil(2, new Callable<Integer>() {
131 waitUntil(true, new Callable<Boolean>() {
144 waitUntil(false, new Callable<Boolean>() {
153 private <T> void waitUntil(T expected, Callable<T> c) throws Exception {
|
| /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...] |
| /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/ojluni/src/main/java/java/util/concurrent/ |
| AbstractExecutorService.java | 65 * protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
97 * Returns a {@code RunnableFuture} for the given callable task.
99 * @param callable the callable task being wrapped
100 * @param <T> the type of the callable's result
102 * underlying callable and which, as a {@code Future}, will yield
103 * the callable's result as its result and provide for
107 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
108 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();
|
| /external/mockito/src/test/java/org/mockitousage/serialization/ |
| AcrossClassLoaderSerializationTest.java | 19 import java.util.concurrent.Callable;
65 public static class CreateMockAndSerializeIt implements Callable<byte[]> {
79 public static class ReadStreamAndDeserializeIt implements Callable<Object> {
|
| /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 | 29 import java.util.concurrent.Callable;
64 new Callable<Boolean>() {
71 PollingCheck.check("accumulator not correct", TIMEOUT_MSEC, new Callable<Boolean>() {
78 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/libmojo/base/android/java/src/org/chromium/base/ |
| ThreadUtils.java | 13 import java.util.concurrent.Callable;
80 * Run the supplied Callable on the main thread, wrapping any exceptions in a RuntimeException.
81 * The method will block until the Callable completes.
83 * @param c The Callable to run
84 * @return The result of the callable
87 public static <T> T runOnUiThreadBlockingNoException(Callable<T> c) {
91 throw new RuntimeException("Error occured waiting for callable", e);
96 * Run the supplied Callable on the main thread, The method will block until the Callable
99 * @param c The Callable to ru
[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> {
|
| /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();
|
| /cts/tests/tests/webkit/src/android/webkit/cts/ |
| ServiceWorkerClientTest.java | 37 import java.util.concurrent.Callable;
152 Callable<Boolean> registrationSuccess = new Callable<Boolean>() {
161 Callable<Boolean> receivedRequest = new Callable<Boolean>() {
|
