diff --git a/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java b/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java
index 7bcb3ed..691fd6e 100644
--- a/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java
+++ b/src/main/java/com/telpo/iotgateway/server/IotSubscribe.java
@@ -51,8 +51,8 @@ public class IotSubscribe {
 
     // 执行单元线程池
     private final static ExecutorService executorService = new ThreadPoolExecutor(
-            Runtime.getRuntime().availableProcessors() - 1,
-            (Runtime.getRuntime().availableProcessors() -1)* 2, 60, TimeUnit.SECONDS,
+            Runtime.getRuntime().availableProcessors() - 2,
+            (Runtime.getRuntime().availableProcessors() -2)* 2, 60, TimeUnit.SECONDS,
             new LinkedBlockingQueue<>(50000));
     // Jms连接侦听
     private static JmsConnectionListener myJmsConnectionListener = new IotJmsConnectionListener();