# parallelStream是用的是默认线程池

整个应用会共用一个线程池,默认核心线程数为cpu核心数。

# 替换默认线程池

//自定义线程池
ForkJoinPool forkJoinPool = new ForkJoinPool(3);  
//提交的Runnable中运行parallelStream逻辑
forkJoinPool.submit(() -> {  
    firstRange.parallelStream().forEach((number) -> {
        try {
            Thread.sleep(5);
        } catch (InterruptedException e) { }
    });
});
 
ForkJoinPool forkJoinPool2 = new ForkJoinPool(3);  
forkJoinPool2.submit(() -> {  
    secondRange.parallelStream().forEach((number) -> {
        try {
            Thread.sleep(5);
        } catch (InterruptedException e) {
        }
    });
});
修改于: 8/11/2022, 3:17:56 PM