From 999a3c46ea136cc69a7fc9d58e14bbac589e1fc5 Mon Sep 17 00:00:00 2001
From: "chen.ma" <machencoding@163.com>
Date: Tue, 27 Jul 2021 22:14:18 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E8=B0=83=E6=95=B4=20Build=20=E7=BA=BF?=
 =?UTF-8?q?=E7=A8=8B=E6=B1=A0=E9=80=BB=E8=BE=91.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java | 2 +-
 .../threadpool/starter/toolkit/thread/ThreadPoolBuilder.java    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java b/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java
index 9f7cde20..a7d0dfa3 100644
--- a/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java
+++ b/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/AbstractBuildThreadPoolTemplate.java
@@ -101,7 +101,7 @@ public class AbstractBuildThreadPoolTemplate {
                         initParam.getTimeUnit(),
                         initParam.getWorkQueue(),
                         initParam.getThreadFactory(),
-                        initParam.rejectedExecutionHandler);
+                        initParam.getRejectedExecutionHandler());
 
         return executorService;
     }
diff --git a/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java b/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java
index d86d8dbc..07edd3c1 100644
--- a/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java
+++ b/dynamic-threadpool-spring-boot-starter/src/main/java/io/dynamic/threadpool/starter/toolkit/thread/ThreadPoolBuilder.java
@@ -235,7 +235,7 @@ public class ThreadPoolBuilder implements Builder<ThreadPoolExecutor> {
 
         // 快速消费线程池内置指定线程池
         if (!builder.isFastPool) {
-            if (builder.workQueue == null) {
+            if (builder.queueType != null) {
                 builder.workQueue = QueueTypeEnum.createBlockingQueue(builder.queueType.type, builder.capacity);
             }
             initParam.setWorkQueue(builder.workQueue);