[ server ] [ executor ]- shell executor optimize - 1

agent/src/main/java/io/wdd/agent/executor/CommandExecutor.java

@@ -1,6 +1,7 @@
 package io.wdd.agent.executor;
 
 import com.google.common.io.ByteStreams;
+import io.wdd.agent.config.utils.AgentCommonThreadPool;
 import io.wdd.agent.executor.redis.StreamSender;
 import io.wdd.agent.executor.thread.LogToArrayListCache;
 import io.wdd.common.beans.executor.ExecutionMessage;
@@ -40,9 +41,13 @@ public class CommandExecutor {
      * @param executionMessage get from EXECUTOR_HANDLER
      */
     public void execute(ExecutionMessage executionMessage) {
-        this.execute(
-                executionMessage.getResultKey(),
-                executionMessage.getCommandList()
+
+        // 防止阻塞消息队列中的其他信息，需要使用异步执行
+        AgentCommonThreadPool.pool.submit(
+                () -> this.execute(
+                        executionMessage.getResultKey(),
+                        executionMessage.getCommandList()
+                )
         );
 
     }

agent/src/main/java/io/wdd/agent/executor/FunctionExecutor.java

@@ -2,6 +2,7 @@ package io.wdd.agent.executor;
 
 import com.alibaba.nacos.api.config.listener.Listener;
 import com.alibaba.nacos.api.exception.NacosException;
+import io.wdd.agent.config.utils.AgentCommonThreadPool;
 import io.wdd.agent.config.utils.NacosConfigurationCollector;
 import io.wdd.common.beans.executor.ExecutionMessage;
 import lombok.extern.slf4j.Slf4j;
@@ -44,7 +45,10 @@ public class FunctionExecutor {
             completeCommandList = ALL_FUNCTION_MAP.get(executionMessage.getType());
         }
 
-        this.execute(resultKey, completeCommandList);
+        // 防止阻塞消息队列中的其他信息，需要使用异步执行
+        AgentCommonThreadPool.pool.submit(
+                () -> this.execute(resultKey, completeCommandList)
+        );
 
     }