| /frameworks/base/packages/StatementService/src/com/android/statementservice/ |
| ExceptionLoggingFutureTask.java | 21 import java.util.concurrent.Callable;
32 public ExceptionLoggingFutureTask(Callable<V> callable, String tag) {
33 super(callable);
|
| /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();
|
| /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-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...] |
| /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...] |
| Executors.java | 27 * ThreadFactory}, and {@link Callable} classes defined in this
40 * <li>Methods that create and return a {@link Callable}
42 * in execution methods requiring {@code Callable}.
339 * Returns a {@link Callable} object that, when
342 * {@code Callable} to an otherwise resultless action.
346 * @return a callable object
349 public static <T> Callable<T> callable(Runnable task, T result) { method in class:Executors
356 * Returns a {@link Callable} object that, when
359 * @return a callable objec
362 public static Callable<Object> callable(Runnable task) { method in class:Executors
375 public static Callable<Object> callable(final PrivilegedAction<?> action) { method in class:Executors
[all...] |
| Callable.java | 14 * <p>The {@code Callable} interface is similar to {@link
21 * convert from other common forms to {@code Callable} classes.
29 public interface Callable<V> {
|
| /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...] |
| 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...] |
| 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/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);
|
| /external/guava/guava-gwt/src-super/java/util/super/java/util/concurrent/ |
| Callable.java | 20 * Emulation of Callable.
24 public interface Callable<V> {
|
| /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/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/jacoco/org.jacoco.core.test/src/org/jacoco/core/test/perf/targets/ |
| Target02.java | 14 import java.util.concurrent.Callable;
19 public class Target02 implements Callable<Void> {
|
| /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();
|
| /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) {
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| FakeTimeLimiter.java | 23 import java.util.concurrent.Callable;
48 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
51 return callable.call(); // fooled you
|
| /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/test/perf/ |
| InstrumentationTimeScenario.java | 14 import java.util.concurrent.Callable;
36 protected Callable<Void> getInstrumentedCallable() throws Exception {
39 return new Callable<Void>() {
|
| /packages/apps/ContactsCommon/src/com/android/contacts/common/compat/ |
| CallableCompat.java | 20 import android.provider.ContactsContract.CommonDataKinds.Callable;
28 Uri.withAppendedPath(Callable.CONTENT_URI, "filter_enterprise");
34 return Callable.CONTENT_FILTER_URI;
|
| /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...] |
| /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 {
|
| /external/guice/core/src/com/google/inject/internal/ |
| ProvisionListenerStackCallback.java | 63 public T provision(Errors errors, InternalContext context, ProvisionCallback<T> callable)
65 Provision provision = new Provision(errors, context, callable);
97 final ProvisionCallback<T> callable; field in class:ProvisionListenerStackCallback.Provision
103 public Provision(Errors errors, InternalContext context, ProvisionCallback<T> callable) {
104 this.callable = callable;
115 result = callable.call();
|
| /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() {
|
