diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/ExecutorRegistryThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/ExecutorRegistryThread.java
index 251465ad..8fe3c964 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/ExecutorRegistryThread.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/ExecutorRegistryThread.java
@@ -36,6 +36,7 @@ public class ExecutorRegistryThread {
             return;
         }
 
+        toStop = false;
         registryThread = new Thread(new Runnable() {
             @Override
             public void run() {
diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobLogFileCleanThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobLogFileCleanThread.java
index 178a82eb..a42d5f01 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobLogFileCleanThread.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/JobLogFileCleanThread.java
@@ -33,6 +33,7 @@ public class JobLogFileCleanThread {
             return;     // effective only when logRetentionDays >= 3
         }
 
+        toStop = false;
         localThread = new Thread(new Runnable() {
             @Override
             public void run() {
diff --git a/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java b/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java
index c0bc07f7..6c91399e 100644
--- a/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java
+++ b/xxl-job-core/src/main/java/com/xxl/job/core/thread/TriggerCallbackThread.java
@@ -61,9 +61,13 @@ public class TriggerCallbackThread {
             return;
         }
 
+
+        toStop = false;
+
         /**
          * trigger callback thread
          */
+
         triggerCallbackThread = new Thread(new Runnable() {
 
             @Override