From f1bc355ff0b325136c18dfc16dd1c276d4cf264a Mon Sep 17 00:00:00 2001 From: Looly Date: Tue, 3 Sep 2024 11:39:58 +0800 Subject: [PATCH] =?UTF-8?q?SyncFinisher=E5=A2=9E=E5=8A=A0setExecutorServic?= =?UTF-8?q?e=E6=96=B9=E6=B3=95=EF=BC=88issue#IANKQ1@Gitee=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- CHANGELOG.md | 2 ++ .../src/main/java/cn/hutool/core/date/DateTime.java | 2 +- .../java/cn/hutool/core/thread/SyncFinisher.java | 12 ++++++++++++ 3 files changed, 15 insertions(+), 1 deletion(-) diff --git a/CHANGELOG.md b/CHANGELOG.md index e6ebd2a14..e5d002708 100755 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,8 @@ # 5.8.33(2024-09-02) ### 🐣新特性 +* 【core 】 SyncFinisher增加setExecutorService方法(issue#IANKQ1@Gitee) + ### 🐞Bug修复 * 【json 】 修复JSONConfig.setDateFormat设置后toBean无效问题(issue#3713@Gitee) diff --git a/hutool-core/src/main/java/cn/hutool/core/date/DateTime.java b/hutool-core/src/main/java/cn/hutool/core/date/DateTime.java index 405f8fa3a..9cea9780f 100644 --- a/hutool-core/src/main/java/cn/hutool/core/date/DateTime.java +++ b/hutool-core/src/main/java/cn/hutool/core/date/DateTime.java @@ -1093,7 +1093,7 @@ public class DateTime extends Date { // issue#3713 尝试使用US Locale解析 try { - DateUtil.newSimpleFormat(pattern, Locale.US, null).parse(dateStr.toString()); + return DateUtil.newSimpleFormat(pattern, Locale.US, null).parse(dateStr.toString()); } catch (Exception ignore) { // ignore } diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/SyncFinisher.java b/hutool-core/src/main/java/cn/hutool/core/thread/SyncFinisher.java index d131f1627..ba1a0c8ba 100644 --- a/hutool-core/src/main/java/cn/hutool/core/thread/SyncFinisher.java +++ b/hutool-core/src/main/java/cn/hutool/core/thread/SyncFinisher.java @@ -57,6 +57,18 @@ public class SyncFinisher implements Closeable { this.workers = new LinkedHashSet<>(); } + /** + * 设置自定义线程池,默认为{@link ExecutorBuilder}创建的线程池 + * + * @param executorService 线程池 + * @return this + * @since 5.8.33 + */ + public SyncFinisher setExecutorService(ExecutorService executorService) { + this.executorService = executorService; + return this; + } + /** * 设置是否所有worker线程同时开始 *