Spring Batch使用ThreadPoolTaskExecutor无限阻塞问题求助

核心线程数设为4时任务阻塞的原因 #

你使用了同一个ThreadPoolTaskExecutor实例处理所有split操作，且该线程池被多个并发Job实例共享。当核心线程数为4时，多个Job同时运行会耗尽线程池可用线程，最终触发死锁：

• 每个Job执行split(executor).add(flowX)时，会把对应Flow提交到线程池执行，发起split的主线程会阻塞等待该Flow完成。
• 多Job并发请求时，核心线程被占满后，新的Flow任务无法获取线程执行，而主线程又在等待任务结束，导致整个任务链永久挂起。

核心线程数设为5时，线程池有足够资源同时处理多个Job的split任务，不会出现线程耗尽的情况，因此任务能正常完成。

是否每个Flow需要独立的ThreadPoolTaskExecutor？ #

不需要为每个Flow配置独立的线程池，但需注意两点：

1. 线程池大小匹配并发需求：根据同时运行的Job实例数量、每个Job内部split的并发数，调整核心线程数和最大线程数，确保线程池有足够资源处理所有并发任务。
2. 规避共享线程池的死锁风险：多Job共享线程池时，要确保队列和线程数配置合理，避免因任务提交阻塞引发死锁（比如避免无界队列搭配过小的线程数，或有界队列满时的拒绝策略不合理）。

另外，你的Job写法是串行执行split操作（每个split在前一个Flow完成后才提交下一个Flow），如果意图是并行执行flow2、flow3、flow4，正确写法应为：

return jobBuilderFactory.get(JobParameter.JOB_NAME).preventRestart()
        .start(flow1)
        .split(executor)
            .add(flow2)
            .add(flow3)
            .add(flow4)
        .end()
        .build();

这种写法会一次性将三个Flow提交到线程池并行执行，能更高效利用线程资源，也降低线程耗尽的风险。

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