From b09520b83e4a43953f327ddcd08ae003e66bed57 Mon Sep 17 00:00:00 2001
From: xuxueli <931591021@qq.com>
Date: Wed, 22 May 2019 17:08:05 +0800
Subject: [PATCH] update document

---
 .../admin/core/thread/JobScheduleHelper.java  | 28 +++++++++++++++----
 1 file changed, 22 insertions(+), 6 deletions(-)

diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java
index 75ebcbd7..807859f4 100644
--- a/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java
+++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/core/thread/JobScheduleHelper.java
@@ -36,13 +36,16 @@ public class JobScheduleHelper {
         scheduleThread = new Thread(new Runnable() {
             @Override
             public void run() {
-                while (!toStop) {
-                    // 随机休眠1s内
-                    try {
-                        TimeUnit.MILLISECONDS.sleep(500+new Random().nextInt(500));
-                    } catch (InterruptedException e) {
+
+                try {
+                    TimeUnit.MILLISECONDS.sleep(5000);
+                } catch (InterruptedException e) {
+                    if (!toStop) {
                         logger.error(e.getMessage(), e);
                     }
+                }
+
+                while (!toStop) {
 
                     // 匹配任务
                     Connection conn = null;
@@ -139,6 +142,16 @@ public class JobScheduleHelper {
                             }
                         }
                     }
+
+                    // 随机休眠1s内
+                    try {
+                        TimeUnit.MILLISECONDS.sleep(500+new Random().nextInt(500));
+                    } catch (InterruptedException e) {
+                        if (!toStop) {
+                            logger.error(e.getMessage(), e);
+                        }
+                    }
+
                 }
                 logger.info(">>>>>>>>>>> xxl-job, JobScheduleHelper#scheduleThread stop");
             }
@@ -154,6 +167,7 @@ public class JobScheduleHelper {
             public void run() {
                 int lastSecond = -1;
                 while (!toStop) {
+
                     try {
                         // second data
                         List<Integer> ringItemData = new ArrayList<>();
@@ -195,7 +209,9 @@ public class JobScheduleHelper {
                     try {
                         TimeUnit.SECONDS.sleep(1);
                     } catch (InterruptedException e) {
-                        logger.error(e.getMessage(), e);
+                        if (!toStop) {
+                            logger.error(e.getMessage(), e);
+                        }
                     }
                 }
                 logger.info(">>>>>>>>>>> xxl-job, JobScheduleHelper#ringThread stop");