parallelStream默认使用了fork-join框架,其默认线程数是CPU核心数。
通过查阅资料,发现有两种方法来修改默认的多线程数量:
1.全局设置
在运行代码之前,加入如下代码:
("", "64");
一般不建议修改,因为修改虽然改进当前的业务逻辑,但对于整个项目中其它地方只是用来做非耗时的并行流运算,性能就不友好了,因为所有使用并行流parallerStream的地方都是使用同一个Fork-Join线程池,而Fork-Join线程数默认仅为cpu的核心数。最好是自己创建一个Fork-Join线程池来用,即下面的方法2。
2.引入Fork-Join Pool
IntStream range = (1, 100000);
// 传入parallelism
new ForkJoinPool(parallelism).submit(() -> ().forEach(::println)).get();
因为我们创建自己的线程池,可以避免共享线程池,如果有需要,甚至可以分配比处理机数量更多的线程。
最后列举一些使用parallelStream需要注意的地方:
线程不安全问题(加锁、使用线程安全的集合或者集合采用collect()
或reduce()
操作就是满足线程安全的;
适用的场景是CPU密集型的,假如本身电脑CPU的负载很大,那还到处用并行流,那并不能起到作用,切记不要再paralelSreram操作是中使用IO流;
3.不要在多线程中使用parallelStream,原因同上类似,大家都抢着CPU是没有提升效果,反而还会加大线程切换开销;