| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ListeningExecutorService.java | 63 * {@code @SuppressWarnings("unchecked") // guaranteed by invokeAll contract}
64 * {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks);}
74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
83 * {@code @SuppressWarnings("unchecked") // guaranteed by invokeAll contract}
84 * {@code List<ListenableFuture<T>> futures = (List) executor.invokeAll(tasks, timeout, unit);}
95 <T> List<Future<T>> invokeAll(
|
| ForwardingExecutorService.java | 54 public <T> List<Future<T>> invokeAll(
56 return delegate().invokeAll(tasks);
60 public <T> List<Future<T>> invokeAll(
63 return delegate().invokeAll(tasks, timeout, unit);
|
| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| ExecutorService.java | 34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
37 <T> List<Future<T>> invokeAll(
|
| AbstractExecutorService.java | 120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
150 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorService.java | 68 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException {
73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException {
|
| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| ExecutorService.java | 64 * Methods {@code invokeAny} and {@code invokeAll} perform the most
277 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
308 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
|
| AbstractExecutorService.java | 48 * {@code invokeAny} and {@code invokeAll} methods using a
233 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
259 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
|
| ForkJoinTask.java | 66 * #invokeAll(ForkJoinTask...) invokeAll}. However, this class also
122 * Method {@code invokeAll} (available in multiple versions)
748 public static void invokeAll(ForkJoinTask<?> t1, ForkJoinTask<?> t2) {
772 public static void invokeAll(ForkJoinTask<?>... tasks) {
[all...] |
| ForkJoinPool.java | [all...] |
| /prebuilts/jdk/jdk8/darwin-x86/sample/forkjoin/mergesort/ |
| MergeSort.java | 91 invokeAll(new MergeSortTask(array, low, middle), new MergeSortTask(array, middle, high));
|
| /prebuilts/jdk/jdk8/linux-x86/sample/forkjoin/mergesort/ |
| MergeSort.java | 91 invokeAll(new MergeSortTask(array, low, middle), new MergeSortTask(array, middle, high));
|
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| SameThreadScheduledExecutorService.java | 100 public <T> List<Future<T>> invokeAll(
103 return delegate.invokeAll(tasks);
107 public <T> List<Future<T>> invokeAll(
112 return delegate.invokeAll(tasks, timeout, unit);
|
| /external/robolectric-shadows/shadows/framework/src/main/java/org/robolectric/android/util/concurrent/ |
| RoboExecutorService.java | 114 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException {
119 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException {
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| ThreadUtil.java | 72 pooledExecutor.invokeAll(callables, timeout, TimeUnit.MILLISECONDS);
74 pooledExecutor.invokeAll(callables);
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| ForkJoinTask8Test.java | 776 * invokeAll(tasks) with 1 argument invokes task
788 invokeAll(f);
795 * invokeAll(t1, t2) invokes all task arguments
810 invokeAll(tasks[0], tasks[1]);
818 * invokeAll(tasks) with > 2 argument invokes tasks
834 invokeAll(tasks[0], tasks[1], tasks[2]);
842 * invokeAll(collection) invokes all tasks in the collection
858 invokeAll(Arrays.asList(tasks));
866 * invokeAll(tasks) with any null task throws NullPointerException
879 () -> invokeAll(nul)
[all...] |
| ForkJoinPool8Test.java | 198 invokeAll(f1, f2);
216 invokeAll(f1, f2);
689 * invokeAll(t1, t2) invokes all task arguments
696 invokeAll(f, g);
706 * invokeAll(tasks) with 1 argument invokes task
712 invokeAll(f);
720 * invokeAll(tasks) with > 2 argument invokes tasks
728 invokeAll(f, g, h);
743 * invokeAll(collection) invokes all tasks in the collection
755 invokeAll(set)
[all...] |
| RecursiveActionTest.java | 187 invokeAll(f1, f2);
205 invokeAll(f1, f2);
876 * invokeAll(t1, t2) invokes all task arguments
883 invokeAll(f, g);
893 * invokeAll(tasks) with 1 argument invokes task
899 invokeAll(f);
907 * invokeAll(tasks) with > 2 argument invokes tasks
915 invokeAll(f, g, h);
930 * invokeAll(collection) invokes all tasks in the collection
942 invokeAll(set)
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| WrappingScheduledExecutorServiceTest.java | 169 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
175 public <T> List<Future<T>> invokeAll(
|
| WrappingExecutorServiceTest.java | 100 List<Future<String>> futures = testExecutor.invokeAll(tasks);
101 mock.assertLastMethodCalled("invokeAll");
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
110 mock.assertMethodWithTimeout("invokeAll", timeout, unit);
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
215 lastMethodCalled = "invokeAll";
217 return inline.invokeAll(tasks);
221 public <T> List<Future<T>> invokeAll(
227 return inline.invokeAll(tasks, timeout, unit);
|
| /packages/apps/DocumentsUI/tests/common/com/android/documentsui/testing/ |
| TestScheduledExecutorService.java | 91 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
97 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout,
|
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.6.Final/ |
| netty-common-4.1.6.Final.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.3.Final/ |
| netty-common-4.1.3.Final.jar | |
| /prebuilts/misc/common/robolectric/3.1.1/lib/ |
| backport-util-concurrent-3.1.jar | |
| /prebuilts/tools/common/m2/repository/backport-util-concurrent/backport-util-concurrent/3.1/ |
| backport-util-concurrent-3.1.jar | |
| /prebuilts/tools/common/m2/repository/io/netty/netty-common/4.1.0.CR3/ |
| netty-common-4.1.0.CR3.jar | |
