更优雅的等待

xxl-job-core/pom.xml

@@ -56,7 +56,7 @@
 		<dependency>
 			<groupId>top.jfunc.common</groupId>
 			<artifactId>utils</artifactId>
-			<version>1.8.2.3</version>
+			<version>1.8.3.5</version>
 		</dependency>
 
 

xxl-job-executor-samples/xxl-job-executor-sample-frameless/src/main/java/com/xuxueli/executor/sample/frameless/Application.java

@@ -3,8 +3,7 @@ package com.xuxueli.executor.sample.frameless;
 import com.xuxueli.executor.sample.frameless.config.FrameLessXxlJobConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
-
-import java.util.concurrent.TimeUnit;
+import top.jfunc.common.thread.HoldProcessor;
 
 /**
  * @author xuxueli 2018-10-31 19:05:43
@@ -18,16 +17,27 @@ public class Application {
             // start
             FrameLessXxlJobConfig.getInstance().initXxlJobExecutor();
 
-            while (true) {
-                TimeUnit.HOURS.sleep(1);
-            }
+            waitHere();
         } catch (Exception e) {
             logger.error(e.getMessage(), e);
-        } finally {
-            // destory
-            FrameLessXxlJobConfig.getInstance().destoryXxlJobExecutor();
         }
 
     }
 
+    private static void waitHere() {
+        final HoldProcessor holdProcessor = new HoldProcessor();
+        holdProcessor.startAwait();
+        logger.info("程序开始等待");
+        Runtime.getRuntime().addShutdownHook(new Thread(){
+            @Override
+            public void run() {
+                logger.info("收到kill 信号，执行清理程序");
+                //在关闭的时候释放资源
+                FrameLessXxlJobConfig.getInstance().destoryXxlJobExecutor();
+                holdProcessor.stopAwait();
+            }
+        });
+    }
+
+
 }