修改线程池阻塞报错

linkwe-common/src/main/java/com/linkwechat/common/utils/Threads.java

@@ -21,8 +21,14 @@ public class Threads
     /**
      * 创建线程池
      */
-    public static final ThreadPoolExecutor SINGLE_THREAD_POOL = new ThreadPoolExecutor(CORE_POOL_SIZE, CORE_POOL_SIZE+1, 10l, TimeUnit.SECONDS,
-            new LinkedBlockingQueue<>(1024),NAMED_THREAD_FACTORY);
+    public static final ThreadPoolExecutor SINGLE_THREAD_POOL = new ThreadPoolExecutor(CORE_POOL_SIZE, CORE_POOL_SIZE + 1, 10l, TimeUnit.SECONDS,
+            new SynchronousQueue<>(), NAMED_THREAD_FACTORY, (r, executor) -> {
+                try {
+                    executor.getQueue().put(r);
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            });
 
 
 

linkwe-wecom/src/main/java/com/linkwechat/wecom/service/impl/WeCustomerServiceImpl.java

@@ -132,12 +132,9 @@ public class WeCustomerServiceImpl extends ServiceImpl<WeCustomerMapper, WeCusto
             Arrays.asList(followUserList.getFollow_user())
                     .stream().forEach(k -> {
                 try {
-                    Threads.SINGLE_THREAD_POOL.execute(new Runnable() {
-                        @Override
-                        public void run() {
-                            SecurityContextHolder.setContext(securityContext);
-                            weFlowerCustomerHandle(k);
-                        }
+                    Threads.SINGLE_THREAD_POOL.execute(() -> {
+                        SecurityContextHolder.setContext(securityContext);
+                        weFlowerCustomerHandle(k);
                     });
                 } catch (Exception e) {
                     e.printStackTrace();