From b6a19a3289b18bd82f938ec6528f192bcae78d1c Mon Sep 17 00:00:00 2001 From: xuxueli <931591021@qq.com> Date: Mon, 21 Oct 2019 17:28:14 +0800 Subject: [PATCH] =?UTF-8?q?JobThread=E8=87=AA=E9=94=80=E6=AF=81=E4=BC=98?= =?UTF-8?q?=E5=8C=96=EF=BC=8C=E9=81=BF=E5=85=8D=E5=B9=B6=E5=8F=91=E8=A7=A6?= =?UTF-8?q?=E5=8F=91=E5=AF=BC=E8=87=B4triggerQueue=E4=B8=AD=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E4=B8=A2=E5=A4=B1=E9=97=AE=E9=A2=98=EF=BC=9B?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- doc/XXL-JOB官方文档.md | 9 +++++---- .../src/main/java/com/xxl/job/core/thread/JobThread.java | 2 +- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/doc/XXL-JOB官方文档.md b/doc/XXL-JOB官方文档.md index 7c581529..e3ea5c4d 100644 --- a/doc/XXL-JOB官方文档.md +++ b/doc/XXL-JOB官方文档.md @@ -1546,10 +1546,11 @@ Tips: 历史版本(V1.3.x)目前已经Release至稳定版本, 进入维护阶段 - 8、DB重连优化,修复DB宕机重连后任务调度停止的问题,重连后自动加入调度集群触发任务调度; - 9、任务触发组件加载顺序调整,避免小概率情况下组件随机加载顺序导致的I18N的NPE问题。 - 10、项目依赖升级至较新稳定版本,如spring、spring-boot、mybatis、slf4j、groovy等等; -- 11、[ING]xxl-rpc服务端线程优化,降低线程内存开销; -- 12、[ING]Cron在线生成工具; -- 13、[ING]调度日志优化:支持设置日志保留天数,过期日志天维度记录报表,并清理;调度报表汇总实时数据和报表; -- 14、[ING]父子任务参数传递;流程任务等,透传动态参数; +- 11、JobThread自销毁优化,避免并发触发导致triggerQueue中任务丢失问题; +- 12、[ING]xxl-rpc服务端线程优化,降低线程内存开销; +- 13、[ING]Cron在线生成工具; +- 14、[ING]调度日志优化:支持设置日志保留天数,过期日志天维度记录报表,并清理;调度报表汇总实时数据和报表; +- 15、[ING]父子任务参数传递;流程任务等,透传动态参数; diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java index a719ed4f..2e1593c2 100644 --- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java +++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java @@ -165,7 +165,7 @@ public class JobThread extends Thread{ } else { if (idleTimes > 30) { - if(triggerQueue ==null||triggerQueue.size()==0) { + if(triggerQueue.size() == 0) { // avoid concurrent trigger causes jobId-lost XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit."); } }