| /dalvik/libcore/suncompat/src/test/java/sun/misc/ |
| UnsafeTest.java | 24 import java.util.concurrent.Callable;
55 Callable<Object> callable = Executors.callable(new Runnable() { local
62 callable.call();
|
| /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,
|
| /dalvik/libcore/concurrent/src/test/java/tests/api/java/util/concurrent/ |
| AbstractExecutorServiceTest.java | 61 * Completed submit(callable) returns result
131 Future future = e.submit(Executors.callable(new PrivilegedAction() {
171 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
208 Future future = e.submit(Executors.callable(new PrivilegedExceptionAction() {
245 * submit(null callable) throws NPE
278 * submit(callable) throws RejectedExecutionException
294 * Blocking on submit(callable) throws InterruptedException if
302 p.submit(new Callable<Object>() {
330 * get of submitted callable throws Exception if callable
[all...] |
| ExecutorsTest.java | 25 static class TimedCallable<T> implements Callable<T> {
27 private final Callable<T> func;
30 TimedCallable(ExecutorService exec, Callable<T> func, long msecs) {
47 private static class Fib implements Callable<BigInteger> {
234 TrackedCallable callable = new TrackedCallable(); local
236 Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
237 assertFalse(callable.done);
239 assertTrue(callable.done);
254 TrackedCallable callable = new TrackedCallable(); local
256 Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS)
274 TrackedCallable callable = new TrackedCallable(); local
[all...] |
| ScheduledExecutorTest.java | 53 * delayed schedule of callable successfully executes after delay
57 TrackedCallable callable = new TrackedCallable(); local
59 Future f = p1.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
60 assertFalse(callable.done);
62 assertTrue(callable.done);
199 TrackedCallable callable = null; local
200 Future f = se.schedule(callable, SHORT_DELAY_MS, TimeUnit.MILLISECONDS);
244 * schedule callable throws RejectedExecutionException if shutdown
680 * completed submit of callable returns result
760 e.invokeAny(new ArrayList<Callable<String>>())
[all...] |
| ExecutorCompletionServiceTest.java | 51 * Submitting a null callable throws NPE
57 Callable c = null;
89 Callable c = new StringTask();
107 Callable c = new StringTask();
126 Callable c = new StringTask();
151 Callable c = new StringTask();
|
| FutureTaskTest.java | 28 public PublicFutureTask(Callable r) { super(r); }
35 * Creating a future with a null callable throws NPE
161 FutureTask task = new FutureTask( new Callable() {
189 FutureTask task = new FutureTask( new Callable() {
217 final FutureTask ft = new FutureTask(new Callable() {
255 final FutureTask ft = new FutureTask(new Callable() {
293 final FutureTask ft = new FutureTask(new Callable() {
331 final FutureTask ft = new FutureTask(new Callable() {
371 final FutureTask ft = new FutureTask(new Callable() {
392 final FutureTask ft = new FutureTask(new Callable() {
[all...] |
| ThreadPoolExecutorTest.java | [all...] |
| /dalvik/libcore/concurrent/src/main/java/java/util/concurrent/ |
| Executors.java | 20 * ThreadFactory}, and {@link Callable} classes defined in this
33 * <li> Methods that create and return a {@link Callable}
35 * in execution methods requiring <tt>Callable</tt>.
327 * Returns a {@link Callable} object that, when
330 * <tt>Callable</tt> to an otherwise resultless action.
333 * @return a callable object
336 public static <T> Callable<T> callable(Runnable task, T result) { method in class:Executors
343 * Returns a {@link Callable} object that, when
346 * @return a callable objec
349 public static Callable<Object> callable(Runnable task) { method in class:Executors
362 public static Callable<Object> callable(final PrivilegedAction action) { method in class:Executors
[all...] |
| FutureTask.java | 20 * <p>A <tt>FutureTask</tt> can be used to wrap a {@link Callable} or
39 * given <tt>Callable</tt>.
41 * @param callable the callable task
42 * @throws NullPointerException if callable is null
44 public FutureTask(Callable<V> callable) {
45 if (callable == null)
47 sync = new Sync(callable);
63 sync = new Sync(Executors.callable(runnable, result))
173 private final Callable<V> callable; field in class:FutureTask.Sync
[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> {
|
| AbstractExecutorService.java | 52 public <T> Future<T> submit(Callable<T> task) {
62 private <T> T doInvokeAny(Collection<Callable<T>> tasks,
85 Iterator<Callable<T>> it = tasks.iterator();
137 public <T> T invokeAny(Collection<Callable<T>> tasks)
147 public <T> T invokeAny(Collection<Callable<T>> tasks,
153 public <T> List<Future<T>> invokeAll(Collection<Callable<T>> tasks)
160 for (Callable<T> t : tasks) {
183 public <T> List<Future<T>> invokeAll(Collection<Callable<T>> tasks,
192 for (Callable<T> t : tasks)
|
| 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 FutureTask<V> newTaskFor(Callable<V> task) {
143 public Future<V> submit(Callable<V> task) {
|
| ScheduledExecutorService.java | 91 * @param callable the function to execute
97 * @throws NullPointerException if callable is null
99 public <V> ScheduledFuture<V> schedule(Callable<V> callable,
|
| /external/opencore/oscl/oscl/osclbase/src/ |
| pvlogger_c.cpp | 24 //C-callable version of PVLogger::GetLoggerObject
30 //C-callable version of PVLogger::IsActive
38 //C-callable version of PVLogger::LogMsgString
|
| pvlogger_c.h | 21 C-callable version
41 //C-callable logging routines.
|
| /dalvik/libcore/archive/src/test/java/java/util/zip/ |
| DeflaterOutputStreamTest.java | 25 import java.util.concurrent.Callable;
65 executor.submit(new Callable<Void>() {
|
| /dalvik/libcore/luni/src/main/java/java/util/ |
| IllegalFormatException.java | 33 // the constructor is not callable from outside from the package
|
| /external/kernel-headers/original/linux/ |
| reboot.h | 71 * Emergency restart, callable from an interrupt handler.
|
| /external/webkit/WebKitTools/pywebsocket/test/testdata/handlers/sub/ |
| non_callable_wsh.py | 31 """Non-callable handlers.
|
| /external/guava/javadoc/com/google/common/util/concurrent/ |
| TimeLimiter.html | 149 <TD><CODE><B><A HREF="../../../../../com/google/common/util/concurrent/TimeLimiter.html#callWithTimeout(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit, boolean)">callWithTimeout</A></B>(<A HREF="http://java.sun.com/javase/6/docs/api/java/util/concurrent/Callable.html?is-external=true" title="class or interface in java.util.concurrent">Callable</A><T> callable,
155 Invokes a specified Callable, timing out after the specified time limit.</TD>
231 <A NAME="callWithTimeout(java.util.concurrent.Callable, long, java.util.concurrent.TimeUnit, boolean)"><!-- --></A><H3>
234 <T> T <B>callWithTimeout</B>(<A HREF="http://java.sun.com/javase/6/docs/api/java/util/concurrent/Callable.html?is-external=true" title="class or interface in java.util.concurrent">Callable</A><T> callable,
240 <DD>Invokes a specified Callable, timing out after the specified time limit
[all...] |
