From 27d45010737f4698f1efe43350e4b96b3887b3b0 Mon Sep 17 00:00:00 2001 From: LuoYe Date: Wed, 4 May 2022 21:26:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=89=A7=E8=A1=8C=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=B1=A0=E5=8F=82=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/io/qyi/e5/config/Start.java | 16 +++++++++++----- 1 file changed, 11 insertions(+), 5 deletions(-) diff --git a/src/main/java/io/qyi/e5/config/Start.java b/src/main/java/io/qyi/e5/config/Start.java index 84d6c8d..76a1956 100644 --- a/src/main/java/io/qyi/e5/config/Start.java +++ b/src/main/java/io/qyi/e5/config/Start.java @@ -38,6 +38,12 @@ public class Start { @Value("${e5.system.threadPool}") Integer poolSize; + @Value("${e5.system.maximumPoolSize}") + int maximumPoolSize; + + @Value("${e5.system.blockingQueueSize}") + int blockingQueueSize; + @Value("${isdebug:true}") private boolean isdebug; @@ -50,16 +56,16 @@ public class Start { // log.info("清空redis...... "); // redisUtil.delAll(); threadPool = new ThreadPoolExecutor( - //指定了线程池中的线程数量，它的数量决定了添加的任务是开辟新的线程去执行，还是放到workQueue任务队列中去； + //要保留在池中的线程数，即使它们处于空闲状态，除非设置了 allowCoreThreadTimeOut poolSize, - //指定了线程池中的最大线程数量，这个参数会根据你使用的workQueue任务队列的类型，决定线程池会开辟的最大线程数量； - poolSize, - //当线程池中空闲线程数量超过corePoolSize时，多余的线程会在多长时间内被销毁； + //池中允许的最大线程数 + maximumPoolSize, + //当线程池中空闲线程数量超过corePoolSize时，多余的线程会在多长时间内被销毁；当线程数大于核心时，这是多余的空闲线程在终止之前等待新任务的最长时间。 0, //unit:keepAliveTime的单位 TimeUnit.MILLISECONDS, //任务队列，被添加到线程池中，但尚未被执行的任务；它一般分为直接提交队列、有界任务队列、无界任务队列、优先任务队列几种； - new LinkedBlockingQueue<>(poolSize), // 有界队列 + new LinkedBlockingQueue<>(blockingQueueSize), // 有界队列 //线程工厂，用于创建线程，一般用默认即可； new CustThreadFactory(), Executors.defaultThreadFactory(), //拒绝策略；当任务太多来不及处理时，如何拒绝任务；