批量获取多条线程的执行结果

2020-05-27

85

2020-07-17 20:19:08

原创

## 场景
一个list，拆分成5份，每份数据放入线程池，返回future。

5个future任务，5个get方法。代码实在不雅观。

如下：

```
List<Integer> list = ListUtil.NEW(1, 2, 3, 4, 5, 6);
List<List<Integer>> lists = ListUtil.splitList(list, 3);
Future<?> future1 = ThreadPool.submit(() -> {
List<Integer> integers = lists.get(0);
integers.forEach(System.out::println);
});
Future<?> future2 = ThreadPool.submit(() -> {
List<Integer> integers = lists.get(1);
integers.forEach(System.out::println);
});
Future<?> future3 = ThreadPool.submit(() -> {
List<Integer> integers = lists.get(2);
integers.forEach(System.out::println);
});
try {
future1.get();
future2.get();
future3.get();
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
```

## 改造

```
List<Integer> sourceList = ListUtil.NEW(1, 2, 3, 4, 5, 6);
List<List<Integer>> lists = ListUtil.splitList(sourceList, 3);
List<Callable<List<Integer>>> tasks = ListUtil.NEW();

lists.forEach(listTemp -> {
    Callable<List<Integer>> task = () -> {
        List<Integer> result = ListUtil.NEW();
        ListUtil.optimize(listTemp).forEach(x -> result.add(x + 1));
        return result;
    };
    ThreadPool.submit(task);
    tasks.add(task);
});

List<List<Integer>> result = ThreadPool.invokeAllTask(tasks);
System.out.println(result);
```

批量获取多条线程的执行结果

评论