Java使用parallelStream()出现ForkJoinPool线程未关闭问题

• 该现象是Java并行流的预期设计行为，和调用方线程是否为主线程无关联，你提到的官方文档描述的特性就是导致该现象的直接原因之一。
• 底层机制说明：
  • parallelStream()默认使用JVM全局共享的ForkJoinPool.commonPool()公共线程池，池内所有工作线程默认均为守护线程，设计定位就是长期存活、等待复用：没有任务时线程会阻塞等待新任务提交，避免反复创建销毁线程带来的性能开销，只要JVM进程还在运行，这些线程就不会主动关闭。
  • 你之前观测到main线程调用没有残留线程，只是因为main方法执行结束后JVM进程直接退出，所有守护线程会被系统强制回收，本质和AWT线程调用的逻辑完全一致。而AWT是UI常驻线程，只要GUI程序未关闭JVM就会持续运行，因此你能观测到公共池线程处于待命状态。
• 该状态不会导致异常问题：公共池的待命线程仅会占用极小的内存资源，后续有新的并行流任务提交时会直接复用这些线程，不会出现资源泄漏。
• 若需要主动控制线程生命周期，可自定义独立ForkJoinPool使用，示例代码如下：

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ForkJoinPool;

// 自定义线程池，并行度可根据业务需求调整
ForkJoinPool customPool = new ForkJoinPool(4);
try {
    // 将并行流任务提交到自定义池执行
    customPool.submit(() -> rssEntry.parallelStream().forEach(System.out::println)).get();
} catch (InterruptedException | ExecutionException e) {
    e.printStackTrace();
} finally {
    // 执行完手动关闭池，池内线程会全部销毁
    customPool.shutdown();
}

内容的提问来源于stack exchange，提问作者Georodin