动态注册Bean运行数日后无响应，PeriodicTrigger触发卡住问题咨询

问题根因分析 #

你当前的实现存在两个核心问题，是触发卡住的主要诱因：

• ThreadPoolTaskExecutor未显式配置参数，默认规则存在严重风险
  Spring的ThreadPoolTaskExecutor默认使用无参构造时，核心线程数为1、队列容量为无界的LinkedBlockingQueue、最大线程数为Integer.MAX_VALUE。当5个流的调度任务同时运行时，核心线程不足的情况下任务会全部堆入无界队列；如果任务出现IO阻塞、死锁、资源未释放等情况，会导致线程被长时间占用，后续新的调度任务根本拿不到执行资源，看起来就像PeriodicTrigger停止了触发。
• 忽略了PeriodicTrigger的默认调度逻辑
  PeriodicTrigger默认关闭fixedRate属性，采用的是fixedDelay逻辑：上一次任务执行完成后，才会间隔2分钟计算下一次触发时间。如果任意一个流的处理任务一直阻塞不返回，对应的调度会直接停止，不会生成下一次触发任务。

修复方案 #

1. 修正ThreadPoolTaskExecutor配置 #

不要使用默认参数，显式设置可控的线程池规则，参考配置如下：

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 核心线程数，建议不低于流的数量，可根据业务处理效率调整为5~10
executor.setCorePoolSize(10);
// 最大线程数根据服务器CPU/内存资源设置，避免无限创建线程
executor.setMaxPoolSize(20);
// 队列必须设置有限容量，避免内存溢出，可根据任务峰值调整为50~200
executor.setQueueCapacity(100);
// 非核心线程空闲超过60秒自动回收
executor.setKeepAliveSeconds(60);
// 拒绝策略调整为CallerRunsPolicy，队列满时由调度线程自身执行任务，及时暴露阻塞问题
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 自定义线程名前缀，后续排查线程栈时可快速定位问题
executor.setThreadNamePrefix("poller-executor-");
// 手动初始化线程池，部分场景下Spring不会自动触发初始化
executor.initialize();

2. 优化调度与任务逻辑 #

• 所有流的处理任务必须增加超时控制，避免IO调用、锁等待等场景无限阻塞
• 如果你需要严格每2分钟触发一次，不受上一次任务执行时长影响，可开启PeriodicTrigger的fixedRate属性：new PeriodicTrigger(2*60*1000L, true)，注意做好任务并发控制避免重复处理
• 给任务增加全局异常捕获和日志埋点，避免异常导致线程意外终止，也方便快速定位故障点

排查建议 #

如果问题复现，优先用jstack命令抓取Java进程的线程栈，查看poller-executor-开头的线程卡在哪个逻辑点，可快速定位是死锁、外部IO阻塞还是业务逻辑问题。

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