forkjoinpool.commonpool() 不该被长期占用，因其是全局共享池，i/o 或阻塞操作会卡住线程，拖慢所有并行流；应改用自定义 forkjoinpool 或 completablefuture 配合专用线程池。
为什么 ForkJoinPool.commonPool() 不该被长期占用
并行流默认用 ForkJoinPool.commonPool()，它是个全局共享池，所有没指定线程池的并行操作（包括第三方库里的 parallelStream()、Arrays.parallelSort()）都往里塞任务。一旦某个耗时 I/O 或阻塞操作卡住几个线程，整个应用的并行流都会变慢甚至死等。
- 常见错误现象：
ForkJoinPool.commonPool-worker-1线程长时间WAITING或BLOCKED，监控看到 CPU 低但响应延迟飙升 - 典型场景：在并行流里调用 HTTP 请求、数据库查询、文件读写——这些不是 CPU 密集型，却霸占了本该留给纯计算任务的线程
- 性能影响：commonPool 默认线程数 = CPU 核数 - 1，哪怕你只启一个阻塞任务，也可能吃掉 1/4 的并发能力
用 ForkJoinPool 构造自定义池并传给 parallelStream()
Java 8 没法直接把线程池“塞进” parallelStream()，得绕一下：把数据转成 Collection 后，用 stream().parallel() 配合自定义 ForkJoinPool 执行 —— 关键是调用 pool.submit(() -> ...).join()。
- 实操建议：别用
new ForkJoinPool(n)，改用带参数的构造函数，显式控制parallelism、factory和handler - 参数差异：
parallelism设为 4～8（非 CPU 核数），避免线程过多；factory建议用ForkJoinPool.defaultForkJoinWorkerThreadFactory并重写makeThread设置线程名，方便排查 - 示例：
ForkJoinPool pool = new ForkJoinPool(4, ForkJoinPool.defaultForkJoinWorkerThreadFactory, (t, e) -> {}, // uncaught exception handler true); // asyncMode = true，更适合 I/O 类任务 List<String> result = pool.submit(() -> data.stream().parallel().map(this::heavyIoCall).collect(Collectors.toList()) ).join();
更干净的方案：用 CompletableFuture.supplyAsync() 替代并行流
如果目标只是并发执行一批相似任务（比如批量查接口），CompletableFuture 比硬套并行流更可控，也天然支持自定义 Executor。
- 使用场景：任务之间无依赖、不需流式中间操作（如
filter、flatMap）、结果只需聚合 - 优势：线程池可复用（比如用
ThreadPoolExecutor），能设拒绝策略、队列容量、空闲线程回收时间 - 容易踩的坑：别用
CompletableFuture.allOf()直接 get 结果——它返回void；要用list.stream().map(CompletableFuture::supplyAsync).map(CompletableFuture::join).collect(...) - 示例：
ExecutorService ioPool = Executors.newFixedThreadPool(10); List<String> result = data.stream() .map(item -> CompletableFuture.supplyAsync(() -> callApi(item), ioPool)) .map(CompletableFuture::join) .collect(Collectors.toList());
别忘了关闭自定义线程池
自定义 ForkJoinPool 或 ExecutorService 不是用完就扔的临时对象，尤其在 Spring Bean 或长生命周期组件里，必须显式关闭，否则 JVM 无法退出。
- 常见错误：在工具类里
static final ForkJoinPool pool = new ForkJoinPool(4)，应用重启时线程没释放，下次启动报端口占用或 OOM - 实操建议：Spring 环境下用
@PreDestroy；普通 Java 应用确保pool.shutdown(); pool.awaitTermination(30, TimeUnit.SECONDS); - 兼容性注意：
ForkJoinPool的shutdown()不会中断正在运行的任务，想强制停止得用shutdownNow()，但可能丢任务
真正麻烦的是那些藏在底层库里的并行流调用——你没法改源码，只能靠监控 commonPool 使用率，提前限流或降级。自定义池不是银弹，而是把不可控变成可控的第一步。
