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 e3e13230..57bdb15a 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 @@ -59,13 +59,18 @@ public class ExecutorRegistryThread extends Thread { } } catch (Exception e) { - logger.error(e.getMessage(), e); + if (!toStop) { + logger.error(e.getMessage(), e); + } + } try { TimeUnit.SECONDS.sleep(RegistryConfig.BEAT_TIMEOUT); } catch (InterruptedException e) { - logger.warn(">>>>>>>>>>> xxl-job, executor registry thread interrupted, error msg:{}", e.getMessage()); + if (!toStop) { + logger.warn(">>>>>>>>>>> xxl-job, executor registry thread interrupted, error msg:{}", e.getMessage()); + } } } 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 bae732b2..dbe56e5b 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 @@ -82,13 +82,18 @@ public class JobLogFileCleanThread extends Thread { } } catch (Exception e) { - logger.error(e.getMessage(), e); + if (!toStop) { + logger.error(e.getMessage(), e); + } + } try { TimeUnit.DAYS.sleep(1); } catch (InterruptedException e) { - logger.error(e.getMessage(), e); + if (!toStop) { + logger.error(e.getMessage(), e); + } } } logger.info(">>>>>>>>>>> xxl-job, executor JobLogFileCleanThread thread destory."); 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 28692169..3ff6f9b7 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 @@ -76,7 +76,9 @@ public class TriggerCallbackThread { } } } catch (Exception e) { - logger.error(e.getMessage(), e); + if (!toStop) { + logger.error(e.getMessage(), e); + } } } @@ -88,7 +90,9 @@ public class TriggerCallbackThread { doCallback(callbackParamList); } } catch (Exception e) { - logger.error(e.getMessage(), e); + if (!toStop) { + logger.error(e.getMessage(), e); + } } logger.info(">>>>>>>>>>> xxl-job, executor callback thread destory.");