ソースを参照

JobThread自销毁优化,避免并发触发导致triggerQueue中任务丢失问题;

xuxueli 5 年 前
コミット
b6a19a3289
共有2 個のファイルを変更した6 個の追加5 個の削除を含む
  1. 5 4
      doc/XXL-JOB官方文档.md
  2. 1 1
      xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java

+ 5 - 4
doc/XXL-JOB官方文档.md ファイルの表示

1546
 - 8、DB重连优化,修复DB宕机重连后任务调度停止的问题,重连后自动加入调度集群触发任务调度;
1546
 - 8、DB重连优化,修复DB宕机重连后任务调度停止的问题,重连后自动加入调度集群触发任务调度;
1547
 - 9、任务触发组件加载顺序调整,避免小概率情况下组件随机加载顺序导致的I18N的NPE问题。
1547
 - 9、任务触发组件加载顺序调整,避免小概率情况下组件随机加载顺序导致的I18N的NPE问题。
1548
 - 10、项目依赖升级至较新稳定版本,如spring、spring-boot、mybatis、slf4j、groovy等等;
1548
 - 10、项目依赖升级至较新稳定版本,如spring、spring-boot、mybatis、slf4j、groovy等等;
1549
-- 11、[ING]xxl-rpc服务端线程优化,降低线程内存开销;
1550
-- 12、[ING]Cron在线生成工具;
1551
-- 13、[ING]调度日志优化:支持设置日志保留天数,过期日志天维度记录报表,并清理;调度报表汇总实时数据和报表;
1552
-- 14、[ING]父子任务参数传递;流程任务等,透传动态参数;
1549
+- 11、JobThread自销毁优化,避免并发触发导致triggerQueue中任务丢失问题;
1550
+- 12、[ING]xxl-rpc服务端线程优化,降低线程内存开销;
1551
+- 13、[ING]Cron在线生成工具;
1552
+- 14、[ING]调度日志优化:支持设置日志保留天数,过期日志天维度记录报表,并清理;调度报表汇总实时数据和报表;
1553
+- 15、[ING]父子任务参数传递;流程任务等,透传动态参数;
1553
 
1554
 
1554
 
1555
 
1555
 
1556
 

+ 1 - 1
xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java ファイルの表示

165
 
165
 
166
 				} else {
166
 				} else {
167
 					if (idleTimes > 30) {
167
 					if (idleTimes > 30) {
168
-						if(triggerQueue ==null||triggerQueue.size()==0) {
168
+						if(triggerQueue.size() == 0) {	// avoid concurrent trigger causes jobId-lost
169
 							XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit.");
169
 							XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit.");
170
 						}
170
 						}
171
 					}
171
 					}