From 9bf26e99d046f12f4776a28c0050089136863586 Mon Sep 17 00:00:00 2001
From: wujiawei <12345678>
Date: Tue, 3 Sep 2024 16:46:20 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90fix=E3=80=91=20=20=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E4=BD=BF=E7=94=A8=E5=AE=8C=E5=90=8E=E4=BD=BF=E7=94=A8=E4=B8=BB?=
 =?UTF-8?q?=E7=BA=BF=E7=A8=8B=E6=89=A7=E8=A1=8C=20ThreadPoolExecutor.Abort?=
 =?UTF-8?q?Policy()?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../network/heartbeat/common/adapter/ChannelFlowAdapter.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java
index bf884f7..4d1f780 100644
--- a/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java
+++ b/wu-lazy-cloud-heartbeat-common/src/main/java/org/framework/lazy/cloud/network/heartbeat/common/adapter/ChannelFlowAdapter.java
@@ -19,7 +19,8 @@ public class ChannelFlowAdapter {
 
     ThreadPoolExecutor CHANNEL_FLOW_ADAPTER_EXECUTOR =
             new ThreadPoolExecutor(20, 200, 3L, TimeUnit.MINUTES,
-                    new LinkedBlockingDeque<>(500));
+                    new LinkedBlockingDeque<>(500),new ThreadPoolExecutor.AbortPolicy());
+    // 线程使用完后使用主线程执行