src/main/java/com/whyc/factory/ThreadPoolExecutorFactory.java
@@ -23,7 +23,7 @@ private static ThreadPoolExecutor init() { //线程池初始化 UserThreadFactory userThreadFactory = new UserThreadFactory("fg"); ThreadPoolExecutor pool = new ThreadPoolExecutor(8, 48, 10, TimeUnit.SECONDS, new LinkedBlockingDeque<>(16), userThreadFactory,new ThreadPoolExecutor.CallerRunsPolicy()); ThreadPoolExecutor pool = new ThreadPoolExecutor(10, 48, 10, TimeUnit.SECONDS, new LinkedBlockingDeque<>(16), userThreadFactory,new ThreadPoolExecutor.CallerRunsPolicy()); poolExecutor = pool; return pool; }