From 2de392bac25c2c448c50357d86345ebf79c71085 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=BE=AE=E7=AC=91=E7=9D=80=E9=9D=A2=E5=AF=B9=E6=98=8E?=
 =?UTF-8?q?=E5=A4=A9?= <752558143@qq.com>
Date: Thu, 25 Jul 2024 20:06:37 +0800
Subject: [PATCH] =?UTF-8?q?=E6=8A=A5=E5=B7=A5=E9=97=AE=E9=A2=98=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cn/estsh/i3plus/ext/mes/pcn/apiservice/mqtt/PcnMqttCallback.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/mqtt/PcnMqttCallback.java b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/mqtt/PcnMqttCallback.java
index 4ea85d2..72ca8da 100644
--- a/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/mqtt/PcnMqttCallback.java
+++ b/modules/i3plus-ext-mes-pcn-apiservice/src/main/java/cn/estsh/i3plus/ext/mes/pcn/apiservice/mqtt/PcnMqttCallback.java
@@ -25,7 +25,7 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 public class PcnMqttCallback implements MqttCallbackExtended {
 
-    private static ExecutorService executorService = new ThreadPoolExecutor(1000, 1000,
+    private static ExecutorService executorService = new ThreadPoolExecutor(200, 200,
             0L, TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<>(10000), r -> {
         Thread thread = new Thread(r);
@@ -33,7 +33,7 @@ public class PcnMqttCallback implements MqttCallbackExtended {
         return thread;
     },new ThreadPoolExecutor.DiscardPolicy());
 
-    private static ExecutorService executorServiceTwo = new ThreadPoolExecutor(1000,1000,
+    private static ExecutorService executorServiceTwo = new ThreadPoolExecutor(200,200,
             0L, TimeUnit.MILLISECONDS,
             new LinkedBlockingQueue<>(10000), r -> {
         Thread thread = new Thread(r);