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);