| /cts/hostsidetests/devicepolicy/app/DeviceAndProfileOwner/src/com/android/cts/deviceandprofileowner/ |
| AudioRestrictionTest.java | 25 import java.util.concurrent.Callable;
30 private final Callable<Boolean> mCheckIfMasterVolumeMuted = new Callable<Boolean>() {
94 waitUntil(2, new Callable<Integer>() {
116 waitUntil(true, new Callable<Boolean>() {
129 waitUntil(false, new Callable<Boolean>() {
138 private <T> void waitUntil(T expected, Callable<T> c) throws Exception {
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| AbstractExecutorServiceTest.java | 20 import java.util.concurrent.Callable;
82 * Completed submit(callable) returns result
118 Future future = e.submit(Executors.callable(new PrivilegedAction() {
139 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
157 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
184 * submit(null callable) throws NPE
189 e.submit((Callable) null);
195 * submit(callable).get() throws InterruptedException if interrupted
200 final Callable<Void> awaiter = new CheckedCallable<Void>() {
223 * get of submit(callable) throws ExecutionException if callabl
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ForwardingExecutorService.java | 23 import java.util.concurrent.Callable;
55 Collection<? extends Callable<T>> tasks) throws InterruptedException {
61 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
74 Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
104 public <T> Future<T> submit(Callable<T> task) {
|
| FakeTimeLimiter.java | 23 import java.util.concurrent.Callable;
48 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
51 return callable.call(); // fooled you
|
| ListeningScheduledExecutorService.java | 21 import java.util.concurrent.Callable;
46 Callable<V> callable, long delay, TimeUnit unit);
|
| AbstractListeningExecutorService.java | 22 import java.util.concurrent.Callable;
28 * {@link ListenableFutureTask} instances for each {@link Runnable} and {@link Callable} submitted
45 @Override protected final <T> ListenableFutureTask<T> newTaskFor(Callable<T> callable) {
46 return ListenableFutureTask.create(callable);
57 @Override public <T> ListenableFuture<T> submit(Callable<T> task) {
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorService.java | 7 import java.util.concurrent.Callable;
42 public <T> Future<T> submit(Callable<T> tCallable) {
68 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException {
73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException {
78 public <T> T invokeAny(Collection<? extends Callable<T>> callables) throws InterruptedException, ExecutionException {
83 public <T> T invokeAny(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/util/ |
| BrNameUtil.java | 19 import android.databinding.tool.reflection.Callable;
43 public static String brKey(Callable callable) {
44 if (callable.type == Callable.Type.FIELD) {
45 return stripPrefixFromField(callable.name);
48 final String name = callable.name;
49 if (isGetter(callable) || isSetter(callable)) {
51 } else if (isBooleanGetter(callable)) {
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| WrappingExecutorServiceTest.java | 32 import java.util.concurrent.Callable;
88 Callable<String> task = Callables.returning(RESULT_VALUE);
96 List<Callable<String>> tasks = createTasks(3);
116 List<Callable<String>> tasks = createTasks(3);
142 private static List<Callable<String>> createTasks(int n) {
143 List<Callable<String>> callables = Lists.newArrayList();
150 private static final class WrappedCallable<T> implements Callable<T> {
151 private final Callable<T> delegate;
153 public WrappedCallable(Callable<T> delegate) {
182 protected <T> Callable<T> wrapTask(Callable<T> callable)
[all...] |
| WrappingScheduledExecutorServiceTest.java | 23 import java.util.concurrent.Callable;
51 testExecutor.schedule(Executors.callable(DO_NOTHING), 5, TimeUnit.SECONDS);
65 private static final class WrappedCallable<T> implements Callable<T> {
66 private final Callable<T> delegate;
68 public WrappedCallable(Callable<T> delegate) {
97 protected <T> Callable<T> wrapTask(Callable<T> callable) {
98 return new WrappedCallable<T>(callable);
134 Callable<V> callable, long delay, TimeUnit unit)
[all...] |
| /cts/common/device-side/util/src/com/android/compatibility/common/util/ |
| PollingCheck.java | 19 import java.util.concurrent.Callable;
60 public static void check(CharSequence message, long timeoutMs, Callable<Boolean> condition)
|
| /cts/libs/deviceutil/src/android/cts/util/ |
| PollingCheck.java | 19 import java.util.concurrent.Callable;
63 public static void check(CharSequence message, long timeout, Callable<Boolean> condition)
|
| /external/jacoco/org.jacoco.agent.rt/src/org/jacoco/agent/rt/internal/ |
| JmxRegistration.java | 15 import java.util.concurrent.Callable;
27 class JmxRegistration implements Callable<Void> {
|
| /external/sl4a/Utils/src/com/googlecode/android_scripting/ |
| MainThread.java | 24 import java.util.concurrent.Callable;
36 public static <T> T run(Context context, final Callable<T> task) {
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/reflection/ |
| Callable.java | 18 public class Callable {
41 public Callable(Type type, String name, String setterName, ModelClass resolvedType,
77 return "Callable{" +
|
| /ndk/tests/device/issue35933-lambda/jni/ |
| issue35933-lambda.cpp | 17 template <class Callable, typename... ArgTypes>
18 void* Call(Callable native_func, ArgTypes&&... args) noexcept
|
| /external/guice/extensions/servlet/src/com/google/inject/servlet/ |
| ServletScopes.java | 32 import java.util.concurrent.Callable;
183 * Wraps the given callable in a contextual callable that "continues" the
199 * <p>The returned callable will throw a {@link ScopingException} when called
202 * @param callable code to be executed in another thread, which depends on
207 * @return a callable that will invoke the given callable, making the request
214 public static <T> Callable<T> continueRequest(final Callable<T> callable,
[all...] |
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ScheduledExecutorService.java | 88 * @param callable the function to execute
91 * @param <V> the type of the callable's result
95 * @throws NullPointerException if callable is null
97 public <V> ScheduledFuture<V> schedule(Callable<V> callable,
|
| /external/droiddriver/droiddriver-android_support_test/src/io/appium/droiddriver/android_support_test/ |
| D2AndroidJUnitRunner.java | 28 import java.util.concurrent.Callable;
39 private static final Callable<Activity> GET_RUNNING_ACTIVITY = new Callable<Activity>() {
|
| /external/guice/extensions/service/src/com/google/inject/service/ |
| AsyncService.java | 21 import java.util.concurrent.Callable;
54 return executor.submit(new Callable<State>() {
79 return executor.submit(new Callable<State>() {
|
| /external/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/perf/ |
| AnalysisTimeScenario.java | 14 import java.util.concurrent.Callable;
38 protected Callable<Void> getInstrumentedCallable() throws Exception {
46 return new Callable<Void>() {
|
| /external/junit/src/org/junit/rules/ |
| ErrorCollector.java | 10 import java.util.concurrent.Callable;
64 checkSucceeds(new Callable<Object>() {
73 * Adds to the table the exception, if any, thrown from {@code callable}.
75 * {@code callable} threw an exception.
77 public Object checkSucceeds(Callable<Object> callable) {
79 return callable.call();
|
| /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/base/packages/DocumentsUI/tests/src/com/android/documentsui/services/ |
| TestScheduledExecutorService.java | 25 import java.util.concurrent.Callable;
72 public <T> Future<T> submit(Callable<T> task) {
87 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
93 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout,
99 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
105 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
123 public <V> ScheduledFuture<V> schedule(Callable<V> callable, long delay, TimeUnit unit) {
|
