| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| CompletionService.java | 73 Future<V> submit(Callable<V> task);
|
| ScheduledExecutorService.java | 117 * @param callable the function to execute
120 * @param <V> the type of the callable's result
124 * @throws NullPointerException if callable is null
126 public <V> ScheduledFuture<V> schedule(Callable<V> callable,
|
| /external/mockito/src/test/java/org/mockitoutil/ |
| SimplePerRealmReloadingClassLoader.java | 8 import java.util.concurrent.Callable;
87 if (instance instanceof Callable) {
88 Callable<?> callableInRealm = (Callable<?>) instance;
94 throw new IllegalArgumentException("qualified name '" + callableCalledInClassLoaderRealm + "' should represent a class implementing Callable");
103 if (instance instanceof Callable) {
104 Callable<?> callableInRealm = (Callable<?>) instance;
111 throw new IllegalArgumentException("qualified name '" + callableCalledInClassLoaderRealm + "' should represent a class implementing Callable");
|
| /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 {
|
| /external/v8/src/interpreter/ |
| interpreter.h | 23 class Callable;
108 void DoStaGlobal(Callable ic, InterpreterAssembler* assembler);
111 void DoStoreIC(Callable ic, InterpreterAssembler* assembler);
114 void DoKeyedStoreIC(Callable ic, InterpreterAssembler* assembler);
143 compiler::Node* BuildLoadGlobal(Callable ic, compiler::Node* context,
156 // Generates code to perform the unary operation via |callable|.
157 compiler::Node* BuildUnaryOp(Callable callable,
|
| /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;
63 public static void check(CharSequence message, long timeout, Callable<Boolean> condition)
|
| /cts/tests/tests/location/src/android/location/cts/ |
| TestUtils.java | 19 import java.util.concurrent.Callable;
50 public static boolean waitForWithCondition(int timeInSec, Callable<Boolean> callback)
|
| /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/mockito/src/main/java/org/mockito/internal/creation/bytebuddy/ |
| MockMethodDispatcher.java | 8 import java.util.concurrent.Callable;
28 public abstract Callable<?> handle(Object instance, Method origin, Object[] arguments) throws Throwable;
|
| /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) {
|
| /external/v8/src/compiler/ |
| js-generic-lowering.h | 39 void ReplaceWithStubCall(Node* node, Callable c, CallDescriptor::Flags flags);
40 void ReplaceWithStubCall(Node* node, Callable c, CallDescriptor::Flags flags,
|
| /frameworks/data-binding/compiler/src/main/java/android/databinding/tool/reflection/ |
| Callable.java | 20 public class Callable {
45 public Callable(Type type, String name, String setterName, ModelClass resolvedType,
82 return "Callable{" +
|
| /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...] |
| /external/droiddriver/src/io/appium/droiddriver/util/ |
| ActivityUtils.java | 25 import java.util.concurrent.Callable;
29 private static final Callable<Activity> GET_RUNNING_ACTIVITY =
30 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/main/java/org/junit/rules/ |
| ErrorCollector.java | 7 import java.util.concurrent.Callable;
63 checkSucceeds(new Callable<Object>() {
72 * Adds to the table the exception, if any, thrown from {@code callable}.
74 * {@code callable} threw an exception.
76 public <T> T checkSucceeds(Callable<T> callable) {
78 return callable.call();
|
