From 1f2dc4fd3aa132260550b43285a612a99027bd35 Mon Sep 17 00:00:00 2001 From: likuan Date: Thu, 22 May 2025 15:04:55 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8F=AF=E5=8F=AC=E5=9B=9E=E6=89=B9=E5=A4=84?= =?UTF-8?q?=E7=90=86=E7=BA=BF=E7=A8=8B=E6=B1=A0=E6=89=A7=E8=A1=8C=E5=99=A8?= =?UTF-8?q?=EF=BC=8C=E5=A2=9E=E5=8A=A0=E5=8C=85=E8=A3=85=E7=B1=BB=E5=A4=84?= =?UTF-8?q?=E7=90=86=E6=96=B9=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../thread/RecyclableBatchThreadPoolExecutor.java | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/hutool-core/src/main/java/cn/hutool/core/thread/RecyclableBatchThreadPoolExecutor.java b/hutool-core/src/main/java/cn/hutool/core/thread/RecyclableBatchThreadPoolExecutor.java index df16985c2..97b55ccbc 100644 --- a/hutool-core/src/main/java/cn/hutool/core/thread/RecyclableBatchThreadPoolExecutor.java +++ b/hutool-core/src/main/java/cn/hutool/core/thread/RecyclableBatchThreadPoolExecutor.java @@ -231,7 +231,7 @@ public class RecyclableBatchThreadPoolExecutor { } /** - * 处理Warp集合 + * 处理Warp数组 * *
{@code
 	 * Warp warp1 = Warp.of(this::select1);
@@ -241,11 +241,20 @@ public class RecyclableBatchThreadPoolExecutor {
 	 * List r2 = warp2.get();
 	 * }
* - * @param warps Warp集合 + * @param warps Warp数组 * @return Warp集合,此方法返回结果为空的不会被过滤 */ public List> processByWarp(Warp... warps) { - return process(Arrays.asList(warps), 1, Warp::execute); + return processByWarp(Arrays.asList(warps)); + } + + /** + * 处理Warp集合 + * @param warps Warp集合 + * @return Warp集合,此方法返回结果为空的不会被过滤 + */ + public List> processByWarp(List> warps) { + return process(warps, 1, Warp::execute); } /**