增加线程池创建

long-article-server/src/main/java/com/tzld/piaoquan/longarticle/service/local/impl/CoreServiceImpl.java

@@ -172,7 +172,7 @@ public class CoreServiceImpl implements CoreService {
 
     private static final int size = 5;
     // 定义一个线程池，设置消费线程的数量
-    private static final ExecutorService executorService = Executors.newFixedThreadPool(size);
+    private static ExecutorService executorService = Executors.newFixedThreadPool(size);
 
 
     @Override
@@ -209,6 +209,10 @@ public class CoreServiceImpl implements CoreService {
             }
         }).start();
 
+        if (executorService.isShutdown() || executorService.isTerminated()) {
+            executorService = Executors.newFixedThreadPool(size);
+        }
+
         // 启动消费者线程
         for (int i = 0; i < size; i++) {
             executorService.submit(new Thread(() -> {