Browse Source

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

xyyz150 5 years ago
parent
commit
44d6be91f1

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

165
 
165
 
166
 				} else {
166
 				} else {
167
 					if (idleTimes > 30) {
167
 					if (idleTimes > 30) {
168
-						XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit.");
168
+						if(triggerQueue ==null||triggerQueue.size()==0) {
169
+							XxlJobExecutor.removeJobThread(jobId, "excutor idel times over limit.");
170
+						}
169
 					}
171
 					}
170
 				}
172
 				}
171
 			} catch (Throwable e) {
173
 			} catch (Throwable e) {