ParallelStreams多線程執行設置線程池數量


// 串行執行流
stream().filter(e -> e > 10).count();
// 並行執行流
parallelStream().filter(e -> e > 10).count()

ParallelStreams 默認使用 ForkJoinPool.commonPool()線程池。

roster.parallelStream().reduce(0, Integer::sum)

 修改線程池大小

ForkJoinPool customThreadPool = new ForkJoinPool(4);
long actualTotal = customThreadPool.submit(() -> roster.parallelStream().reduce(0, Integer::sum)).get();

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM