目录
- 1 需求
- 2 单机串行
- 3 丢弃后续调整
- 4 覆盖之前的调整
1 需求
每一个任务都有一个阻塞处理策略,我们在创建任务的时候可以自己设置,那么不同的设置,后端的逻辑是什么呢》
xxljob 调度中心项目 调度我们自己的项目,到了我们项目里面,最先到的文件是
就在首次到的这个文件的逻辑里面,就对这个阻塞处理策略进行了判断,
先根据jobid 从map里面获取到jobThread,这个任务线程
如果线程不为空,那么就获取到当前任务的阻塞处理策略;
2 单机串行
// push data to queue 将触发参数 放到 触发队列里面
ReturnT<String> pushResult = jobThread.pushTriggerQueue