| /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);
|
| WrappingExecutorService.java | 114 public final <T> List<Future<T>> invokeAll(
116 return delegate.invokeAll(wrapTasks(tasks));
120 public final <T> List<Future<T>> invokeAll(
123 return delegate.invokeAll(wrapTasks(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(
|
| /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,
|
| Executors.java | 642 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
644 return e.invokeAll(tasks);
646 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
649 return e.invokeAll(tasks, timeout, unit);
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| AbstractExecutorServiceTest.java | 318 * invokeAll(null) throws NPE
324 e.invokeAll(null);
331 * invokeAll(empty collection) returns empty collection
336 List<Future<String>> r = e.invokeAll(new ArrayList<Callable<String>>());
342 * invokeAll(c) throws NPE if c has null elements
351 e.invokeAll(l);
358 * get of returned element of invokeAll(c) throws exception on failed task
365 List<Future<String>> futures = e.invokeAll(l);
377 * invokeAll(c) returns results of all completed tasks in c
385 List<Future<String>> futures = e.invokeAll(l)
[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...] |
| ForkJoinTaskTest.java | 804 * invokeAll(t1, t2) invokes all task arguments
811 invokeAll(f, g);
821 * invokeAll(tasks) with 1 argument invokes task
827 invokeAll(f);
835 * invokeAll(tasks) with > 2 argument invokes tasks
843 invokeAll(f, g, h);
855 * invokeAll(collection) invokes all tasks in the collection
867 invokeAll(set);
879 * invokeAll(tasks) with any null task throws NPE
888 invokeAll(f, g, h)
[all...] |
| 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...] |
| 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...] |
| ForkJoinPoolTest.java | 703 * invokeAll(null) throws NullPointerException
709 e.invokeAll(null);
716 * invokeAll(empty collection) returns empty collection
722 = e.invokeAll(new ArrayList<Callable<String>>());
728 * invokeAll(c) throws NullPointerException if c has null elements
737 e.invokeAll(l);
744 * get of returned element of invokeAll(c) throws
752 List<Future<String>> futures = e.invokeAll(l);
764 * invokeAll(c) returns results of all completed tasks in c
772 List<Future<String>> futures = e.invokeAll(l)
[all...] |
| CountedCompleterTest.java | [all...] |
| ScheduledExecutorSubclassTest.java | [all...] |
| ScheduledExecutorTest.java | [all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| 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);
|
| /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 {
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| ThreadUtil.java | 72 pooledExecutor.invokeAll(callables, timeout, TimeUnit.MILLISECONDS);
74 pooledExecutor.invokeAll(callables);
|
| /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);
|
| /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/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 {
|
| /art/test/522-checker-regression-monitor-exit/src/ |
| Main.java | 69 List<Future<Integer>> results = pool.invokeAll(queries);
|
| /external/dagger2/core/src/test/java/dagger/internal/ |
| DoubleCheckLazyTest.java | 59 List<Future<Object>> futures = executor.invokeAll(tasks);
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| TestingExecutorsTest.java | 73 List<Future<Boolean>> futureList = executor.invokeAll(
|
