From 46095b42fd4788cf054f6cc889c89a7232adeb68 Mon Sep 17 00:00:00 2001
From: MiniDay <372403923@qq.com>
Date: Wed, 2 Nov 2022 09:59:19 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E9=87=8D=E6=96=B0=E6=B7=BB=E5=8A=A0=20?=
 =?UTF-8?q?WORKER=5FEXECUTOR?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../hamster3/mc/plugin/core/bukkit/HamsterCorePlugin.java | 2 ++
 .../hamster3/mc/plugin/core/bungee/HamsterCorePlugin.java | 2 ++
 .../plugin/core/common/constant/CoreConstantObjects.java  | 8 +++++++-
 3 files changed, 11 insertions(+), 1 deletion(-)

diff --git a/hamster-core-bukkit/src/main/java/cn/hamster3/mc/plugin/core/bukkit/HamsterCorePlugin.java b/hamster-core-bukkit/src/main/java/cn/hamster3/mc/plugin/core/bukkit/HamsterCorePlugin.java
index 3280809..67ffe41 100644
--- a/hamster-core-bukkit/src/main/java/cn/hamster3/mc/plugin/core/bukkit/HamsterCorePlugin.java
+++ b/hamster-core-bukkit/src/main/java/cn/hamster3/mc/plugin/core/bukkit/HamsterCorePlugin.java
@@ -74,6 +74,8 @@ public class HamsterCorePlugin extends JavaPlugin {
         Logger logger = getLogger();
         long start = System.currentTimeMillis();
         logger.info("仓鼠核心正在关闭...");
+        CoreConstantObjects.WORKER_EXECUTOR.shutdownNow();
+        logger.info("已暂停 WORKER_EXECUTOR.");
         CoreConstantObjects.SCHEDULED_EXECUTOR.shutdownNow();
         logger.info("已暂停 SCHEDULED_EXECUTOR.");
         long time = System.currentTimeMillis() - start;
diff --git a/hamster-core-bungeecord/src/main/java/cn/hamster3/mc/plugin/core/bungee/HamsterCorePlugin.java b/hamster-core-bungeecord/src/main/java/cn/hamster3/mc/plugin/core/bungee/HamsterCorePlugin.java
index 01b2e22..6d5c8db 100644
--- a/hamster-core-bungeecord/src/main/java/cn/hamster3/mc/plugin/core/bungee/HamsterCorePlugin.java
+++ b/hamster-core-bungeecord/src/main/java/cn/hamster3/mc/plugin/core/bungee/HamsterCorePlugin.java
@@ -43,6 +43,8 @@ public class HamsterCorePlugin extends Plugin {
         Logger logger = getLogger();
         long start = System.currentTimeMillis();
         logger.info("仓鼠核心正在关闭...");
+        CoreConstantObjects.WORKER_EXECUTOR.shutdownNow();
+        logger.info("已暂停 WORKER_EXECUTOR.");
         CoreConstantObjects.SCHEDULED_EXECUTOR.shutdownNow();
         logger.info("已暂停 SCHEDULED_EXECUTOR.");
         long time = System.currentTimeMillis() - start;
diff --git a/hamster-core-common/src/main/java/cn/hamster3/mc/plugin/core/common/constant/CoreConstantObjects.java b/hamster-core-common/src/main/java/cn/hamster3/mc/plugin/core/common/constant/CoreConstantObjects.java
index a0ddf75..a94ae8f 100644
--- a/hamster-core-common/src/main/java/cn/hamster3/mc/plugin/core/common/constant/CoreConstantObjects.java
+++ b/hamster-core-common/src/main/java/cn/hamster3/mc/plugin/core/common/constant/CoreConstantObjects.java
@@ -6,6 +6,7 @@ import org.jetbrains.annotations.NotNull;
 
 import java.lang.reflect.Type;
 import java.util.UUID;
+import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.ScheduledExecutorService;
 import java.util.concurrent.ThreadFactory;
@@ -33,10 +34,15 @@ public interface CoreConstantObjects {
             .setPrettyPrinting()
             .create();
 
+    /**
+     * 异步线程
+     */
+    ExecutorService WORKER_EXECUTOR = Executors.newCachedThreadPool(new NamedThreadFactory("HamsterCore - Executor"));
     /**
      * 调度器线程
      */
-    ScheduledExecutorService SCHEDULED_EXECUTOR = Executors.newScheduledThreadPool(1, new NamedThreadFactory("HamsterCore - Scheduler"));
+    ScheduledExecutorService SCHEDULED_EXECUTOR = Executors
+            .newScheduledThreadPool(1, new NamedThreadFactory("HamsterCore - Scheduler"));
 
 }