优化在JobThread尝试30次后销毁任务时，并发插入到triggerQueue中任务会失败的场景

d35bc023 · xyyz150 · 4dabb4b1 · d35bc023
隐藏空白更改
内联并排

Showing with 3 addition and 1 deletion

xxl-job-core/src/main/java/com/xxl/job/core/thread/JobThread.java ...core/src/main/java/com/xxl/job/core/thread/JobThread.java +3 -1

未找到文件。
--- 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,9 @@ public class JobThread extends Thread{

 				} else {
 					if (idleTimes > 30) {
-						XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit.");
+						if(triggerQueue ==null||triggerQueue.size()==0) {
+							XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit.");
+						}
 					}
 				}
 			} catch (Throwable e) {