src/main/java/com/whyc/factory/ThreadPoolExecutorFactory.java | ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 |
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.MINUTES, new LinkedBlockingDeque<>(5), userThreadFactory); ThreadPoolExecutor pool = new ThreadPoolExecutor(8, 48, 10, TimeUnit.SECONDS, new LinkedBlockingDeque<>(16), userThreadFactory,new ThreadPoolExecutor.CallerRunsPolicy()); poolExecutor = pool; return pool; }