Spring Cloud Stream含PollableChannel的集成流致定时任务无法触发

核心机制冲突 #

1. 全局TaskScheduler的复用
   Spring Boot自动配置的ThreadPoolTaskScheduler是默认的全局任务调度器，既用于执行@Scheduled标记的定时任务，也会被Spring Integration自动复用，用于驱动PollableChannel的轮询逻辑。这个调度器默认线程池大小为1（由配置项spring.task.scheduling.pool.size控制）。

2. 轮询任务阻塞导致线程饥饿
   当你的MessageSource返回null（无消息可拉取）时，Spring Integration的轮询任务会持续占用调度器的线程——默认逻辑下，无消息时轮询任务会进入阻塞等待状态，或因超时设置过长一直持有线程。由于默认调度器只有1个线程，定时任务的cron触发请求会因为没有可用线程资源而无法执行，最终表现为定时任务“停止触发”。

是否属于框架bug？ #

这不属于潜在bug，而是自动配置默认行为与业务场景的适配冲突：

• Spring Boot默认的单线程调度器是为简单定时任务场景设计的，足以应对常规的非阻塞定时任务；
• Spring Integration复用全局调度器是为了减少资源开销，但未考虑到轮询任务的阻塞特性会抢占定时任务的线程资源。

你采用的自定义TaskScheduler方案是合理的：通过为定时任务单独配置独立的调度器，隔离定时任务与Spring Integration轮询任务的线程池，从根本上避免了资源竞争问题。

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