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 866670ec471779cdc17ff3696cf84298196e638b..a719ed4f6c44db5f0bc5885e17b81b4c3c8f4359 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,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) {