背景
业务需要定时捞取数据库中新增的数据做数据处理及分析，更新状态，处理结束。而我们不能随意定义线程池，规定使用统一的标准规范来定义线程池。如在配置文件中配置线程池的属性：名称，线程核心数等，任务属性：任务名称，任务处理类，延迟信息等等。定义好这些信息后，启动系统时，线程池就会初始化并开始执行任务。
业务实现
- Spring监听器
使用Spring容器启动结束发布的ApplicationReadyEvent事件来初始化线程池。
@EventListener
public void onApplicationReadyEvent(ApplicationReadyEvent event) {
log.info("监听器启动线程池。。。");
jobManager.start();
}
- 线程池统一处理类
public void start() {
AbstractJob job = context.getAutowireCapableBeanFactory().createBean(BusinessJob.class);
threadPool.scheduleWithFixedDelay(job, 1000, 1000, TimeUnit.MILLISECONDS);
}
- 任务处理抽象类
所有任务都会继承这个抽象类，它定义了一些公共的行为，比如看门狗监视任务是否正常执行。看门口属性被定义为这个抽象类的属性，它是直接导致任务失效的直接原因
@Override
public void run() {
log.info("==========AbstractJob start===========");
try {
work();
watchDog.print();
} catch (Throwable t) {
logger.log(Level.WARNING, "aaa bbb ccc", t);
}
log.info("==========AbstractJob end=============");
}
protected abstract void work();
- 任务处理类（继承上面的抽象类）
该类被定义为Spring Bean对象
@Override
public void work() {
log.info("job start.");
handle();
log.info("job end.");
}
public void handle(){
// 处理业务
}
新需求
由于某种原因业务提出新需求，而这个需求需要支持事务，于是根据以前学过的知识，直接在任务处理类中定义@Transactional注解的方法，通过Spring循环依赖，注入了自己。
@Override
public void work() {
log.info("job start.");
handle();
// job
job.testTransaction();
log.info("job end.");
}
@Transactional
public void testTransaction() {
log.info("execute transaction.");
jdbcTemplate.execute("update user set name='rick1' where id = 3");
// jdbcTemplate.execute("insert into user values('1', 'rick')");
log.info("execute transaction end.");
}
本地测试发现执行正常，提交代码。
万万没想到，测试反馈，定时任务只跑了一次就停止了，也没有异常信息
也是本地重新启动发现确实跑了一次任务就停了。于是将@Transactional注解干掉，任务正常的执行。所以将事务方法重新定义一个类，加上@Component注解，通过bean对象引入到任务类中。
至此，业务是开发完了，但是出现这种问题的原因还没有分析清楚，随后就有了上面的demo复现问题。
猜测
@Transactional注解原理是生成一个代理对象包裹原生创建的Bean对象，是不是启动时生成的代理对象将原来传递到线程池的任务被丢弃了。于是把所有涉及的源码开始分析起来
- 获取任务添加到线程池
从Spring容器中获取的Bean对象是个代理对象，所以线程池里面执行的任务是个代理对象
- ScheduledThreadPoolExecutor线程池
执行scheduleWithFixedDelay()方法- 检验
- 封装任务
- 调用delayedExecute()方法执行任务，最终调用ThreadPoolExecutor类ensurePrestart()方法，将任务提交到线程池执行
线程池启动线程执行的是ScheduledThreadPoolExecutor内部类的ScheduledFutureTask类run()方法
第一次执行任务时调用的是runAndReset()方法，如果任务执行成功，则返回true，通过reExecutePeriodic()将任务重新添加到线程池去执行；如果任务执行失败抛异常，则返回false，任务就被丢弃了，也就是跑一次，后面就不跑了。
顺着这个思路返回去看任务执行过程，如果抛异常了，那就证明这个迷就解开了。c.call()就会调用我们定义的任务抽象类，它又会调用work()方法，而从日志得知work()正常执行完成，所以问题极大可能出现在抽象类里面，work()执行完了以后调用watchDog对象的方法，此时Debug发现watchDog对象为空，也就出现了空指针异常，这个异常会被捕获，并打印出来，此时又离谱的事来了，任务类的代理对象的logger属性又是空的，所以又出现了空指针异常抛出去了，导致任务停止执行。
为什么代理对象的属性都为空呢
Spring代理对象所有属性都为空，只有被代理对象的属性有值。可以参考这篇文章
