ThreadUtil.newExecutor等方法变更方法签名，返回值变更为ThreadPoolExecutor

dromara · Jun 30, 2024 · db5806f · db5806f
1 parent a8e959c
commit db5806f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -14,6 +14,7 @@
 * 【cache  】      Cache.put变更策略，对于替换的键值对，不清理队列（issue#3618@Github）
 * 【core   】      添加 Windows 资源管理器风格字符串比较器（pr#3620@Github）
 * 【core   】      Week.of支持中文名称（issue#3637@Github）
+* 【core   】      ThreadUtil.newExecutor等方法变更方法签名，返回值变更为ThreadPoolExecutor（pr#1230@Gitee）
 
 ### 🐞Bug修复
 * 【core   】      修复AnnotationUtil可能的空指针错误

diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java b/hutool-core/src/main/java/cn/hutool/core/thread/ThreadUtil.java
@@ -54,7 +54,7 @@ public static ThreadPoolExecutor newExecutor(int corePoolSize) {
 	 *
 	 * @return ExecutorService
 	 */
-	public static ExecutorService newExecutor() {
+	public static ThreadPoolExecutor newExecutor() {
 		return ExecutorBuilder.create().useSynchronousQueue().build();
 	}
 
@@ -102,7 +102,7 @@ public static ThreadPoolExecutor newExecutor(int corePoolSize, int maximumPoolSi
 	 * @return {@link ThreadPoolExecutor}
 	 * @since 5.4.1
 	 */
-	public static ExecutorService newExecutor(int corePoolSize, int maximumPoolSize, int maximumQueueSize) {
+	public static ThreadPoolExecutor newExecutor(int corePoolSize, int maximumPoolSize, int maximumQueueSize) {
 		return ExecutorBuilder.create()
 				.setCorePoolSize(corePoolSize)
 				.setMaxPoolSize(maximumPoolSize)
@@ -147,7 +147,7 @@ public static ThreadPoolExecutor newExecutorByBlockingCoefficient(float blocking
 	 * @author luozongle
 	 * @since 5.8.0
 	 */
-	public static ExecutorService newFixedExecutor(int nThreads, String threadNamePrefix, boolean isBlocked) {
+	public static ThreadPoolExecutor newFixedExecutor(int nThreads, String threadNamePrefix, boolean isBlocked) {
 		return newFixedExecutor(nThreads, 1024, threadNamePrefix, isBlocked);
 	}
 
@@ -167,7 +167,7 @@ public static ExecutorService newFixedExecutor(int nThreads, String threadNamePr
 	 * @author luozongle
 	 * @since 5.8.0
 	 */
-	public static ExecutorService newFixedExecutor(int nThreads, int maximumQueueSize, String threadNamePrefix, boolean isBlocked) {
+	public static ThreadPoolExecutor newFixedExecutor(int nThreads, int maximumQueueSize, String threadNamePrefix, boolean isBlocked) {
 		return newFixedExecutor(nThreads, maximumQueueSize, threadNamePrefix,
 				(isBlocked ? RejectPolicy.BLOCK : RejectPolicy.ABORT).getValue());
 	}
@@ -187,7 +187,7 @@ public static ExecutorService newFixedExecutor(int nThreads, int maximumQueueSiz
 	 * @author luozongle
 	 * @since 5.8.0
 	 */
-	public static ExecutorService newFixedExecutor(int nThreads,
+	public static ThreadPoolExecutor newFixedExecutor(int nThreads,
 												   int maximumQueueSize,
 												   String threadNamePrefix,
 												   RejectedExecutionHandler handler) {