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());
+    // 线程使用完后使用主线程执行