| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| CallablesTest.java | 21 import java.util.concurrent.Callable;
34 Callable<Object> callable = Callables.returning(value); local
35 assertSame(value, callable.call());
37 assertSame(value, callable.call());
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListenableFutureTask.java | 19 import java.util.concurrent.Callable;
42 * given {@code Callable}.
44 * @param callable the callable task
47 public static <V> ListenableFutureTask<V> create(Callable<V> callable) {
48 return new ListenableFutureTask<V>(callable);
68 private ListenableFutureTask(Callable<V> callable) {
69 super(callable);
[all...] |
| FakeTimeLimiter.java | 21 import java.util.concurrent.Callable;
43 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
45 return callable.call(); // fooled you
|
| TimeLimiter.java | 21 import java.util.concurrent.Callable;
82 * Invokes a specified Callable, timing out after the specified time limit.
91 * @param callable the Callable to execute
98 * @return the result returned by the Callable
104 <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
|
| SimpleTimeLimiter.java | 31 import java.util.concurrent.Callable;
100 Callable<Object> callable = new Callable<Object>() {
111 return callWithTimeout(callable, timeoutDuration, timeoutUnit,
120 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
122 checkNotNull(callable);
126 Future<T> future = executor.submit(callable);
|
| MoreExecutors.java | 25 import java.util.concurrent.Callable;
461 Callable<V> callable, long delay, TimeUnit unit) {
462 return delegate.schedule(callable, delay, unit);
|
| /external/jmonkeyengine/engine/src/core/com/jme3/app/ |
| AppTask.java | 51 private final Callable<V> callable; field in class:AppTask
61 * {@link Callable}.
63 * @param callable The callable to be executed
65 public AppTask(Callable<V> callable) {
66 this.callable = callable;
136 public Callable<V> getCallable()
[all...] |
| /frameworks/ex/variablespeed/tests/src/com/android/ex/variablespeed/ |
| RealMediaPlayerTest.java | 21 import java.util.concurrent.Callable;
34 Callable<MediaPlayer> callable = new Callable<MediaPlayer>() { local
40 FutureTask<MediaPlayer> future = new FutureTask<MediaPlayer>(callable);
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| ScheduledExecutorService.java | 88 * @param callable the function to execute
94 * @throws NullPointerException if callable is null
96 public <V> ScheduledFuture<V> schedule(Callable<V> callable,
|
| FutureTask.java | 21 * <p>A {@code FutureTask} can be used to wrap a {@link Callable} or
72 /** The underlying callable; nulled out after running */
73 private Callable<V> callable; field in class:FutureTask
76 /** The thread running the callable; CASed during run() */
99 * given {@code Callable}.
101 * @param callable the callable task
102 * @throws NullPointerException if the callable is null
104 public FutureTask(Callable<V> callable)
[all...] |
| Executors.java | 22 * ThreadFactory}, and {@link Callable} classes defined in this
35 * <li> Methods that create and return a {@link Callable}
37 * in execution methods requiring <tt>Callable</tt>.
297 * Returns a {@link Callable} object that, when
300 * <tt>Callable</tt> to an otherwise resultless action.
303 * @return a callable object
306 public static <T> Callable<T> callable(Runnable task, T result) { method in class:Executors
313 * Returns a {@link Callable} object that, when
316 * @return a callable objec
319 public static Callable<Object> callable(Runnable task) { method in class:Executors
332 public static Callable<Object> callable(final PrivilegedAction<?> action) { method in class:Executors
[all...] |
| ForkJoinTask.java | 15 import java.util.concurrent.Callable;
147 * and {@link Callable}, that may be of use when mixing execution of
1249 final Callable<? extends T> callable; field in class:ForkJoinTask.AdaptedCallable
[all...] |
| ScheduledThreadPoolExecutor.java | 66 * {@code Callable}) that can be used to customize the concrete task
85 * Callable<V> c, RunnableScheduledFuture<V> task) {
201 ScheduledFutureTask(Callable<V> callable, long ns) {
202 super(callable);
378 * Modifies or replaces the task used to execute a callable.
383 * @param callable the submitted Callable
384 * @param task the task created to execute the callable
385 * @return a task that can execute the callable
[all...] |
| AbstractExecutorService.java | 30 * protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
61 * Returns a <tt>RunnableFuture</tt> for the given callable task.
63 * @param callable the callable task being wrapped
65 * underlying callable and which, as a <tt>Future</tt>, will yield
66 * the callable's result as its result and provide for
70 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
71 return new FutureTask<T>(callable);
100 public <T> Future<T> submit(Callable<T> task)
[all...] |
| /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/jmonkeyengine/engine/src/core/com/jme3/scene/control/ |
| UpdateControl.java | 38 import java.util.concurrent.Callable;
47 * mySpatial.getControl(UpdateControl.class).enqueue(new Callable() {
61 * Enqueues a task/callable object to execute in the jME3
64 public <V> Future<V> enqueue(Callable<V> callable) {
65 AppTask<V> task = new AppTask<V>(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();
|
| /external/webkit/Tools/Scripts/webkitpy/test/ |
| skip.py | 37 if not callable(attr):
|
| /external/v8/test/mjsunit/ |
| array-tostring.js | 29 // is callable. Otherwise, just use the original Object.toString function.
52 // Non-callable join function is ignored and Object.prototype.toString is
55 a3.join = "not callable";
58 // Non-existing join function is treated same as non-callable.
90 // Non-callable join works same as for Array.
93 join: "not callable"};
131 // If toLocaleString of element is not callable, throw a TypeError.
132 var la2 = [1, {toLocaleString: "not callable"}, 3];
135 // If toLocaleString of element is callable, call it.
|
| json.js | 60 valueOf: "not callable",
67 valueOf: "not callable",
68 toString: "not callable either",
73 valueOf: "not callable",
83 ISOString: "not callable"};
356 numFoo.valueOf = "not callable";
366 str37.toString = "not callable";
372 var func = function() { /* Is callable */ };
374 var funcJSON = function() { /* Is callable */ };
377 var re = /Is callable/;
[all...] |
| object-toprimitive.js | 87 toStringFunc = "not callable";
94 valueOfFunc = "not callable";
|
| /external/junit/src/org/junit/internal/runners/ |
| MethodRoadie.java | 6 import java.util.concurrent.Callable;
60 Callable<Object> callable= new Callable<Object>() {
66 Future<Object> result= service.submit(callable);
|
| /external/robolectric/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();
|
| /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);
143 return runOnUiThreadAndGetTheResult(new Callable<List<TextView>>() {
|
| /cts/tests/tests/media/src/android/media/cts/ |
| MediaPlayerFlakyNetworkTest.java | 37 import java.util.concurrent.Callable;
197 Callable<MediaPlayer> callable = new Callable<MediaPlayer>() { local
203 FutureTask<MediaPlayer> future = new FutureTask<MediaPlayer>(callable);
|
