| /libcore/luni/src/main/java/java/util/concurrent/ |
| D | AbstractExecutorService.java | 126 ArrayList<Future<T>> futures = new ArrayList<>(ntasks); in doInvokeAny() local
144 futures.add(ecs.submit(it.next())); in doInvokeAny()
153 futures.add(ecs.submit(it.next())); in doInvokeAny()
184 cancelAll(futures); in doInvokeAny()
208 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
212 futures.add(f); in invokeAll()
215 for (int i = 0, size = futures.size(); i < size; i++) { in invokeAll()
216 Future<T> f = futures.get(i); in invokeAll()
223 return futures; in invokeAll()
225 cancelAll(futures); in invokeAll()
[all …]
|
| D | ForkJoinPool.java | 2807 ArrayList<Future<T>> futures = new ArrayList<>(tasks.size()); in invokeAll() local
2812 futures.add(f); in invokeAll()
2815 for (int i = 0, size = futures.size(); i < size; i++) in invokeAll()
2816 ((ForkJoinTask<?>)futures.get(i)).quietlyJoin(); in invokeAll()
2817 return futures; in invokeAll()
2819 for (int i = 0, size = futures.size(); i < size; i++) in invokeAll()
2820 futures.get(i).cancel(false); in invokeAll()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | AbstractExecutorServiceTest.java | 365 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
366 assertEquals(1, futures.size()); in testInvokeAll4()
368 futures.get(0).get(); in testInvokeAll4()
385 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
386 assertEquals(2, futures.size()); in testInvokeAll5()
387 for (Future<String> future : futures) in testInvokeAll5()
549 List<Future<String>> futures =
551 assertEquals(1, futures.size());
553 futures.get(0).get();
570 List<Future<String>> futures =
[all …]
|
| D | ScheduledExecutorSubclassTest.java | 1039 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
1040 assertEquals(1, futures.size()); in testInvokeAll4()
1042 futures.get(0).get(); in testInvokeAll4()
1059 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
1060 assertEquals(2, futures.size()); in testInvokeAll5()
1061 for (Future<String> future : futures) in testInvokeAll5()
1223 List<Future<String>> futures =
1225 assertEquals(1, futures.size());
1227 futures.get(0).get();
1244 List<Future<String>> futures =
[all …]
|
| D | ScheduledExecutorTest.java | 988 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
989 assertEquals(1, futures.size()); in testInvokeAll4()
991 futures.get(0).get(); in testInvokeAll4()
1008 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
1009 assertEquals(2, futures.size()); in testInvokeAll5()
1010 for (Future<String> future : futures) in testInvokeAll5()
1173 List<Future<String>> futures =
1175 assertEquals(1, futures.size());
1177 futures.get(0).get();
1194 List<Future<String>> futures =
[all …]
|
| D | ThreadPoolExecutorTest.java | 1629 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
1630 assertEquals(1, futures.size()); in testInvokeAll4()
1632 futures.get(0).get(); in testInvokeAll4()
1652 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
1653 assertEquals(2, futures.size()); in testInvokeAll5()
1654 for (Future<String> future : futures) in testInvokeAll5()
1851 List<Future<String>> futures =
1853 assertEquals(1, futures.size());
1855 futures.get(0).get();
1875 List<Future<String>> futures =
[all …]
|
| D | ThreadPoolExecutorSubclassTest.java | 1622 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
1623 assertEquals(1, futures.size()); in testInvokeAll4()
1625 futures.get(0).get(); in testInvokeAll4()
1645 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
1646 assertEquals(2, futures.size()); in testInvokeAll5()
1647 for (Future<String> future : futures) in testInvokeAll5()
1844 List<Future<String>> futures =
1846 assertEquals(1, futures.size());
1848 futures.get(0).get();
1868 List<Future<String>> futures =
[all …]
|
| D | ForkJoinPoolTest.java | 752 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll4() local
753 assertEquals(1, futures.size()); in testInvokeAll4()
755 futures.get(0).get(); in testInvokeAll4()
772 List<Future<String>> futures = e.invokeAll(l); in testInvokeAll5() local
773 assertEquals(2, futures.size()); in testInvokeAll5()
774 for (Future<String> future : futures) in testInvokeAll5()
939 List<Future<String>> futures
941 assertEquals(1, futures.size());
943 futures.get(0).get();
960 List<Future<String>> futures
[all …]
|
| D | FutureTaskTest.java | 825 final List<Future<?>> futures = new ArrayList<>(); in testGet_NegativeInfinityTimeout() local
834 futures.add(pool.submit(r)); in testGet_NegativeInfinityTimeout()
837 for (Future<?> future : futures) in testGet_NegativeInfinityTimeout()
|
| D | JSR166TestCase.java | 939 ArrayList<Future<?>> futures = new ArrayList<>(actions.length);
941 futures.add(pool.submit(new CheckedRunnable() {
943 for (Future<?> future : futures)
|