From aca20d542703b25aed758f0616e76a7c32e7b037 Mon Sep 17 00:00:00 2001
From: limqhz <l>
Date: Wed, 22 Jul 2020 10:18:21 +0800
Subject: [PATCH] =?UTF-8?q?api-=E4=BF=AE=E6=94=B9=E7=BA=BF=E7=A8=8B?=
 =?UTF-8?q?=E6=B1=A0=E5=86=85=E5=AE=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/NettyWeiXinApplication.java | 30 -------------------
 .../com/sv/api/InterceptorConfigurer.java     | 15 ++++++++++
 2 files changed, 15 insertions(+), 30 deletions(-)

diff --git a/api/src/main/java/com/NettyWeiXinApplication.java b/api/src/main/java/com/NettyWeiXinApplication.java
index 364625f..275f3c0 100644
--- a/api/src/main/java/com/NettyWeiXinApplication.java
+++ b/api/src/main/java/com/NettyWeiXinApplication.java
@@ -25,7 +25,6 @@ public class NettyWeiXinApplication {
      * @param args 启动参数
      */
     public static void main(String[] args) {
-//        SpringApplication.run(NettyWeiXinApplication.class, args);
         ConfigurableApplicationContext context = SpringApplication.run(NettyWeiXinApplication.class, args);
         SpringContextHolder.setContext(context);
         //启动netty
@@ -33,33 +32,4 @@ public class NettyWeiXinApplication {
         bootService.run();
     }
 
-
-    /**
-     * 项目可能又使用计划任务的
-     */
-//    private int corePoolSize = 5;//线程池维护线程的最少数量
-//
-//    private int maxPoolSize = 15;//线程池维护线程的最大数量
-//
-//    private int queueCapacity = 5; //缓存队列
-//
-//    private int keepAlive = 60;//允许的空闲时间
-//    @Bean("scheduledExecutorService")
-//    public ScheduledExecutorService initScheduledExecutorService() {
-//        ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(400,
-//                new BasicThreadFactory.Builder().namingPattern("example-schedule-pool-%d").daemon(true).build());
-//        return executorService;
-//    }
-//    @Bean
-//    public Executor executor() {
-//        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-//        executor.setCorePoolSize(corePoolSize);
-//        executor.setMaxPoolSize(maxPoolSize);
-//        executor.setQueueCapacity(queueCapacity);
-//        executor.setThreadNamePrefix("mqExecutor-");
-//        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
-//        executor.setKeepAliveSeconds(keepAlive);
-//        executor.initialize();
-//        return executor;
-//    }
 }
diff --git a/api/src/main/java/com/sv/api/InterceptorConfigurer.java b/api/src/main/java/com/sv/api/InterceptorConfigurer.java
index bceb748..022b348 100644
--- a/api/src/main/java/com/sv/api/InterceptorConfigurer.java
+++ b/api/src/main/java/com/sv/api/InterceptorConfigurer.java
@@ -2,6 +2,7 @@ package com.sv.api;
 
 import com.sv.api.interceptor.AccessTokensInterceptorNew;
 import com.sv.api.interceptor.PlatformInterceptor;
+import org.apache.commons.lang3.concurrent.BasicThreadFactory;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
@@ -10,6 +11,8 @@ import org.springframework.web.servlet.config.annotation.WebMvcConfigurerAdapter
 import javax.annotation.Resource;
 import java.util.concurrent.Executor;
 import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.ScheduledThreadPoolExecutor;
 
 /**
  * Spring Mvc Configuration
@@ -42,4 +45,16 @@ public class InterceptorConfigurer extends WebMvcConfigurerAdapter {
     public Executor initExecutor(){
         return Executors.newFixedThreadPool(10);
     }
+
+    /**
+     * 延迟任务
+     * @return
+     */
+    @Bean("scheduledExecutorService")
+    public ScheduledExecutorService initScheduledExecutorService() {
+        ScheduledExecutorService executorService = new ScheduledThreadPoolExecutor(400,
+                new BasicThreadFactory.Builder().namingPattern("netty-door-pool-%d").daemon(true).build());
+        return executorService;
+    }
+
 }