问题遇到的现象和发生背景
使用自定义Fork线程池是否需要手动关闭线程池?
ForkJoinPool pool = new ForkJoinPool(4);
//示例代码
ForkJoinPool pool = new ForkJoinPool(4);
Map<String, Object> resultMap = new ConcurrentHashMap<>(3);
pool.submit(() -> {
Stream.iterate(BigInteger.ZERO,n->n.add(BigInteger.ONE)).limit(3).parallel().forEach((k) -> {
Map<String, Object> map = new HashMap<>();
map.put("name", name);
Random random = new Random();
map.put("age", random.nextInt(100));
resultMap.put(String.valueOf(k), map);
});
}).join();
pool.shutdown();
return resultMap;
运行结果及报错内容
我的解答思路和尝试过的方法
ForkJoinPool.commonPool()使用的是公共池, 很容易受其他业务影响, 公共池是随便使用无需关闭的, 但是自定义线程池是否需要手动关闭呢? 关闭或者不关有什么影响吗?