HomeSort by relevance Sort by last modified time
    Searched refs:callable (Results 1 - 25 of 40) sorted by null

1 2

  /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();
  /external/guava/src/com/google/common/util/concurrent/
FakeTimeLimiter.java 19 import java.util.concurrent.Callable;
38 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration,
40 return callable.call(); // fooled you
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);
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,
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);
  /libcore/luni/src/main/java/java/util/concurrent/
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...]
ScheduledExecutorService.java 89 * @param callable the function to execute
95 * @throws NullPointerException if callable is null
97 public <V> ScheduledFuture<V> schedule(Callable<V> callable,
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...]
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);
374 * Modifies or replaces the task used to execute a callable.
379 * @param callable the submitted Callable
380 * @param task the task created to execute the callable
381 * @return a task that can execute the callable
    [all...]
AbstractExecutorService.java 34 * protected &lt;V&gt; RunnableFuture&lt;V&gt; newTaskFor(Callable&lt;V&gt; 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...]
  /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...]
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...]
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...]
  /packages/providers/DownloadProvider/tests/src/tests/http/
MockWebServer.java 34 import java.util.concurrent.Callable;
117 submitCallable(new Callable<Void>() {
135 submitCallable(new Callable<Void>() {
166 private void submitCallable(Callable<?> callable) {
167 Future<?> future = executor.submit(callable);
  /external/sonivox/arm-hybrid-22k/lib_src/
ARM-E_mastergain_gnu.s 6 @ C-callable.
ARM-E_interpolate_loop_gnu.s 6 @ C-callable.
ARM-E_interpolate_noloop_gnu.s 6 @ C-callable.
ARM-E_voice_gain_gnu.s 6 @ C-callable.
  /external/sonivox/arm-wt-22k/lib_src/
ARM-E_mastergain_gnu.s 6 @ C-callable.
ARM-E_interpolate_loop_gnu.s 6 @ C-callable.
  /external/webkit/WebKitTools/pywebsocket/mod_pywebsocket/
dispatch.py 111 if not callable(handler):
112 raise DispatchError('%s is not callable.' % name)
  /frameworks/base/core/tests/utillib/src/coretestutils/http/
MockWebServer.java 35 import java.util.concurrent.Callable;
135 submitCallable(new Callable<Void>() {
153 submitCallable(new Callable<Void>() {
184 private void submitCallable(Callable<?> callable) {
185 Future<?> future = executor.submit(callable);
  /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/protobuf/python/
mox.py 216 obj: A Python object (class, module, instance, callable).
381 if callable(getattr(class_to_mock, method)):
491 """Provide custom logic for mocking classes that are callable."""
493 # Verify the class we are mocking is callable
494 callable = self._class_to_mock.__dict__.get('__call__', None)
495 if callable is None:
496 raise TypeError('Not callable')
511 """Callable mock method.
742 side_effects: A callable which modifies the parameters or other relevant
1116 in order to validate it. You can use this to have a callable validate an
    [all...]

Completed in 713 milliseconds

1 2