| /libcore/luni/src/test/java/tests/api/java/util/concurrent/ |
| ExecutorsTest.java | 182 TrackedCallable callable = new TrackedCallable(); local
184 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
185 assertFalse(callable.done);
187 assertTrue(callable.done);
196 TrackedCallable callable = new TrackedCallable(); local
198 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
199 assertFalse(callable.done);
201 assertTrue(callable.done);
210 TrackedCallable callable = new TrackedCallable(); local
212 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS)
[all...] |
| AbstractExecutorServiceTest.java | 51 * Completed submit(callable) returns result
88 Future future = e.submit(Executors.callable(new PrivilegedAction() {
109 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
127 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
155 * submit(null callable) throws NPE
160 e.submit((Callable) null);
189 * submit(callable) throws RejectedExecutionException
213 * Blocking on submit(callable) throws InterruptedException if
235 * get of submitted callable throws InterruptedException if callable
[all...] |
| ScheduledExecutorSubclassTest.java | 57 protected <V> RunnableScheduledFuture<V> decorateTask(Callable<V> c, RunnableScheduledFuture<V> task) {
94 * delayed schedule of callable successfully executes after delay
97 TrackedCallable callable = new TrackedCallable(); local
99 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
100 assertFalse(callable.done);
102 assertTrue(callable.done);
209 TrackedCallable callable = null; local
210 Future f = se.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
250 * schedule callable throws RejectedExecutionException if shutdown
636 * completed submit of callable returns resul
[all...] |
| ScheduledExecutorTest.java | 41 * delayed schedule of callable successfully executes after delay
44 TrackedCallable callable = new TrackedCallable(); local
46 Future f = p1.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
47 assertFalse(callable.done);
49 assertTrue(callable.done);
158 TrackedCallable callable = null; local
159 Future f = se.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
199 * schedule callable throws RejectedExecutionException if shutdown
587 * completed submit of callable returns result
648 e.invokeAny(new ArrayList<Callable<String>>())
[all...] |
| ExecutorCompletionServiceTest.java | 47 * Submitting a null callable throws NPE
53 Callable c = null;
85 Callable c = new StringTask();
101 Callable c = new StringTask();
118 Callable c = new StringTask();
141 Callable c = new StringTask();
151 * Submitting to underlying AES that overrides newTaskFor(Callable)
157 MyCallableFuture(Callable<V> c) { super(c); }
163 protected <T> RunnableFuture<T> newTaskFor(Callable<T> c) {
171 Callable<String> c = new StringTask()
[all...] |
| ThreadPoolExecutorSubclassTest.java | 24 final Callable<V> callable; field in class:ThreadPoolExecutorSubclassTest.CustomTask
32 CustomTask(Callable<V> c) {
34 callable = c;
38 callable = new Callable<V>() {
74 v = callable.call();
121 protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
[all...] |
| ThreadPoolExecutorTest.java | [all...] |
| /external/guava/src/com/google/common/util/concurrent/ |
| Callables.java | 19 import java.util.concurrent.Callable;
24 * Static utility methods pertaining to the {@link Callable} interface.
33 * Creates a {@code Callable} which immediately returns a preset value each
36 public static <T> Callable<T> returning(final @Nullable T value) {
37 return new Callable<T>() {
|
| ListenableFutureTask.java | 19 import java.util.concurrent.Callable;
40 * given {@code Callable}.
42 * @param callable the callable task
43 * @throws NullPointerException if callable is null
45 public ListenableFutureTask(Callable<V> callable) {
46 super(callable);
|
| FakeTimeLimiter.java | 19 import java.util.concurrent.Callable;
38 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
40 return callable.call(); // fooled you
|
| SimpleTimeLimiter.java | 29 import java.util.concurrent.Callable;
97 Callable<Object> callable = new Callable<Object>() {
107 return callWithTimeout(callable, timeoutDuration, timeoutUnit,
115 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
117 checkNotNull(callable);
120 Future<T> future = executor.submit(callable);
|
| TimeLimiter.java | 19 import java.util.concurrent.Callable;
79 * Invokes a specified Callable, timing out after the specified time limit.
88 * @param callable the Callable to execute
95 * @return the result returned by the Callable
101 <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
|
| /libcore/luni/src/test/java/sun/misc/ |
| UnsafeTest.java | 21 import java.util.concurrent.Callable;
39 Callable<Object> callable = Executors.callable(new Runnable() { local
46 callable.call();
|
| /libcore/luni/src/main/java/java/util/concurrent/ |
| Executors.java | 23 * ThreadFactory}, and {@link Callable} classes defined in this
36 * <li> Methods that create and return a {@link Callable}
38 * in execution methods requiring <tt>Callable</tt>.
330 * Returns a {@link Callable} object that, when
333 * <tt>Callable</tt> to an otherwise resultless action.
336 * @return a callable object
339 public static <T> Callable<T> callable(Runnable task, T result) { method in class:Executors
346 * Returns a {@link Callable} object that, when
349 * @return a callable objec
352 public static Callable<Object> callable(Runnable task) { method in class:Executors
365 public static Callable<Object> callable(final PrivilegedAction<?> action) { method in class:Executors
[all...] |
| FutureTask.java | 21 * <p>A <tt>FutureTask</tt> can be used to wrap a {@link Callable} or
40 * given <tt>Callable</tt>.
42 * @param callable the callable task
43 * @throws NullPointerException if callable is null
45 public FutureTask(Callable<V> callable) {
46 if (callable == null)
48 sync = new Sync(callable);
64 sync = new Sync(Executors.callable(runnable, result))
174 private final Callable<V> callable; field in class:FutureTask.Sync
[all...] |
| AbstractExecutorService.java | 34 * protected <V> RunnableFuture<V> newTaskFor(Callable<V> c) {
65 * Returns a <tt>RunnableFuture</tt> for the given callable task.
67 * @param callable the callable task being wrapped
69 * underlying callable and which, as a <tt>Future</tt>, will yield
70 * the callable's result as its result and provide for
74 protected <T> RunnableFuture<T> newTaskFor(Callable<T> callable) {
75 return new FutureTask<T>(callable);
104 public <T> Future<T> submit(Callable<T> task)
[all...] |
| Callable.java | 14 * <p>The <tt>Callable</tt> interface is similar to {@link
21 * convert from other common forms to <tt>Callable</tt> classes.
28 public interface Callable<V> {
|
| ExecutorCompletionService.java | 28 * Collection<Callable<Result>> solvers)
32 * for (Callable<Result> s : solvers)
48 * Collection<Callable<Result>> solvers)
57 * for (Callable<Result> s : solvers)
95 private RunnableFuture<V> newTaskFor(Callable<V> task) {
149 public Future<V> submit(Callable<V> task) {
|
| /frameworks/base/docs/html/sdk/api_diff/9/changes/ |
| java.util.concurrent.ExecutorService.html | 86 <A NAME="java.util.concurrent.ExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>)"></A>
87 <nobr><code>List<Future<T>></code> invokeAll(<code>Collection<Callable<T>></code>)</nobr>
93 <A NAME="java.util.concurrent.ExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>, long, java.util.concurrent.TimeUnit)"></A>
94 <nobr><code>List<Future<T>></code> invokeAll(<code>Collection<Callable<T>>,</nobr> long<nobr>,</nobr> TimeUnit<nobr><nobr></code>)</nobr>
100 <A NAME="java.util.concurrent.ExecutorService.invokeAny_removed(java.util.Collection<java.util.concurrent.Callable<T>>)"></A>
101 <nobr><code>T</code> invokeAny(<code>Collection<Callable<T>></code>)</nobr>
107 <A NAME="java.util.concurrent.ExecutorService.invokeAny_removed(java.util.Collection<java.util.concurrent.Callable<T>>, long, java.util.concurrent.TimeUnit)"></A>
108 <nobr><code>T</code> invokeAny(<code>Collection<Callable<T>>,</nobr> long<nobr>,</nobr> TimeUnit<nobr><nobr></code>)</nobr>
122 <A NAME="java.util.concurrent.ExecutorService.invokeAll_added(java.util.Collection<? extends java.util.concurrent.Callable<T>>)"></A>
123 <nobr><code>List<Future<T>></code> <A HREF="../../../../reference/java/util/concurrent/ExecutorService.html#invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>>)" target="_top"><code>invokeAll</code></A>(<code>Collection<Callable<T>></code>)</ (…)
[all...] |
| java.util.concurrent.AbstractExecutorService.html | 86 <A NAME="java.util.concurrent.AbstractExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>)"></A>
87 <nobr><code>List<Future<T>></code> invokeAll(<code>Collection<Callable<T>></code>)</nobr>
93 <A NAME="java.util.concurrent.AbstractExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>, long, java.util.concurrent.TimeUnit)"></A>
94 <nobr><code>List<Future<T>></code> invokeAll(<code>Collection<Callable<T>>,</nobr> long<nobr>,</nobr> TimeUnit<nobr><nobr></code>)</nobr>
100 <A NAME="java.util.concurrent.AbstractExecutorService.invokeAny_removed(java.util.Collection<java.util.concurrent.Callable<T>>)"></A>
101 <nobr><code>T</code> invokeAny(<code>Collection<Callable<T>></code>)</nobr>
107 <A NAME="java.util.concurrent.AbstractExecutorService.invokeAny_removed(java.util.Collection<java.util.concurrent.Callable<T>>, long, java.util.concurrent.TimeUnit)"></A>
108 <nobr><code>T</code> invokeAny(<code>Collection<Callable<T>>,</nobr> long<nobr>,</nobr> TimeUnit<nobr><nobr></code>)</nobr>
122 <A NAME="java.util.concurrent.AbstractExecutorService.invokeAll_added(java.util.Collection<? extends java.util.concurrent.Callable<T>>)"></A>
123 <nobr><code>List<Future<T>></code> <A HREF="../../../../reference/java/util/concurrent/AbstractExecutorService.html#invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>>)" target="_top"><code>invokeAll</code></A>(<code>Collection<Callable<T>></code>)</ (…)
[all...] |
| java.util.concurrent.Executors.html | 87 <nobr><code>Callable<Object></code> callable(<code>PrivilegedAction</code>)</nobr>
94 <nobr><code>Callable<Object></code> callable(<code>PrivilegedExceptionAction</code>)</nobr>
109 <nobr><code>Callable<Object></code> <A HREF="../../../../reference/java/util/concurrent/Executors.html#callable(java.security.PrivilegedAction<?>)" target="_top"><code>callable</code></A>(<code>PrivilegedAction<?></code>)</nobr>
116 <nobr><code>Callable<Object></code> <A HREF="../../../../reference/java/util/concurrent/Executors.html#callable(java.security.PrivilegedExceptionAction<?>)" target="_top"><code>callable</code></A>(<code>PrivilegedExceptionAction<?></code>)</nobr
[all...] |
| methods_index_removals.html | 59 <i>callable</i><br>
130 <nobr><A HREF="java.util.concurrent.AbstractExecutorService.html#java.util.concurrent.AbstractExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>)" class="hiddenlink" target="rightframe">type <strike>
131 (<code>Collection<Callable<T>></code>)</strike> in java.util.concurrent.AbstractExecutorService
133 <nobr><A HREF="java.util.concurrent.AbstractExecutorService.html#java.util.concurrent.AbstractExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>, long, java.util.concurrent.TimeUnit)" class="hiddenlink" target="rightframe">type <strike>
134 (<code>Collection<Callable<T>>, long, TimeUnit</code>)</strike> in java.util.concurrent.AbstractExecutorService
136 <nobr><A HREF="java.util.concurrent.ExecutorService.html#java.util.concurrent.ExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>)" class="hiddenlink" target="rightframe">type <strike>
137 (<code>Collection<Callable<T>></code>)</strike> in java.util.concurrent.ExecutorService
139 <nobr><A HREF="java.util.concurrent.ExecutorService.html#java.util.concurrent.ExecutorService.invokeAll_removed(java.util.Collection<java.util.concurrent.Callable<T>>, long, java.util.concurrent.TimeUnit)" class="hiddenlink" target="rightframe">type <strike>
140 (<code>Collection<Callable<T>>, long, TimeUnit</code>)</strike> in java.util.concurrent.ExecutorService
143 <nobr><A HREF="java.util.concurrent.AbstractExecutorService.html#java.util.concurrent.AbstractExecutorService.invokeAny_removed(java.util.Collection<java.util.concurrent.Callable<T>>)" class="hiddenlink" target="rightframe">type <strike
[all...] |
| /libcore/support/src/test/java/libcore/javax/net/ssl/ |
| TestSSLSocketPair.java | 19 import java.util.concurrent.Callable;
68 Future s = executor.submit(new Callable<Void>() {
77 Future c = executor.submit(new Callable<Void>() {
|
| /libcore/support/src/test/java/tests/http/ |
| MockWebServer.java | 39 import java.util.concurrent.Callable;
159 executor.submit(namedCallable("MockWebServer-accept-" + port, new Callable<Void>() {
231 executor.submit(namedCallable(name, new Callable<Void>() {
433 private static <T> Callable<T> namedCallable(final String name, final Callable<T> callable) {
434 return new Callable<T>() {
439 return callable.call();
|
| /external/kernel-headers/original/linux/ |
| reboot.h | 71 * Emergency restart, callable from an interrupt handler.
|
