设置并行流自定义线程池的技巧

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 使用率，提前限流或降级。自定义池不是银弹，而是把不可控变成可控的第一步。