| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ForwardingExecutorService.java | 67 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
69 return delegate().invokeAny(tasks);
73 public <T> T invokeAny(
76 return delegate().invokeAny(tasks, timeout, unit);
|
| WrappingExecutorService.java | 127 public final <T> T invokeAny(Collection<? extends Callable<T>> tasks)
129 return delegate.invokeAny(wrapTasks(tasks));
133 public final <T> T invokeAny(
136 return delegate.invokeAny(wrapTasks(tasks), timeout, unit);
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| ExecutorService.java | 41 <T> T invokeAny(Collection<? extends Callable<T>> tasks)
44 <T> T invokeAny(
|
| AbstractExecutorService.java | 104 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
114 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| ExecutorService.java | 64 * Methods {@code invokeAny} and {@code invokeAll} perform the most
331 <T> T invokeAny(Collection<? extends Callable<T>> tasks)
357 <T> T invokeAny(Collection<? extends Callable<T>> tasks,
|
| Executors.java | 651 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
653 return e.invokeAny(tasks);
655 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
658 return e.invokeAny(tasks, timeout, unit);
|
| AbstractExecutorService.java | 48 * {@code invokeAny} and {@code invokeAll} methods using a
145 * the main mechanics of invokeAny.
217 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
227 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorService.java | 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 {
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| AbstractExecutorServiceTest.java | 244 * invokeAny(null) throws NPE
250 e.invokeAny(null);
257 * invokeAny(empty collection) throws IAE
263 e.invokeAny(new ArrayList<Callable<String>>());
270 * invokeAny(c) throws NPE if c has null elements
280 e.invokeAny(l);
287 * invokeAny(c) throws ExecutionException if no task in c completes
295 e.invokeAny(l);
304 * invokeAny(c) returns result of some task in c if at least one completes
312 String result = e.invokeAny(l)
[all...] |
| ForkJoinPoolTest.java | 613 * invokeAny(null) throws NullPointerException
619 e.invokeAny(null);
626 * invokeAny(empty collection) throws IllegalArgumentException
632 e.invokeAny(new ArrayList<Callable<String>>());
639 * invokeAny(c) throws NullPointerException if c has a single null element
647 e.invokeAny(l);
654 * invokeAny(c) throws NullPointerException if c has null elements
664 e.invokeAny(l);
672 * invokeAny(c) throws ExecutionException if no task in c completes
680 e.invokeAny(l)
[all...] |
| ScheduledExecutorSubclassTest.java | [all...] |
| ScheduledExecutorTest.java | [all...] |
| ThreadPoolExecutorSubclassTest.java | [all...] |
| ThreadPoolExecutorTest.java | [all...] |
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| SameThreadScheduledExecutorService.java | 116 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
119 return delegate.invokeAny(tasks);
123 public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
128 return delegate.invokeAny(tasks, timeout, unit);
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| RoboExecutorService.java | 124 public <T> T invokeAny(Collection<? extends Callable<T>> callables) throws InterruptedException, ExecutionException {
129 public <T> T invokeAny(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException, ExecutionException, TimeoutException {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| WrappingExecutorServiceTest.java | 120 String s = testExecutor.invokeAny(tasks);
122 mock.assertLastMethodCalled("invokeAny");
129 String s = testExecutor.invokeAny(tasks, timeout, unit);
131 mock.assertMethodWithTimeout("invokeAny", timeout, unit);
230 // Define the invokeAny methods to invoke the first task
232 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
235 lastMethodCalled = "invokeAny";
240 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
| WrappingScheduledExecutorServiceTest.java | 182 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
188 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| TestScheduledExecutorService.java | 103 public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
109 public <T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
|