可召回批处理线程池执行器,增加包装类处理方法

This commit is contained in:
likuan
2025-05-22 15:04:55 +08:00
parent 7a2ef283ff
commit 1f2dc4fd3a

View File

@@ -231,7 +231,7 @@ public class RecyclableBatchThreadPoolExecutor {
} }
/** /**
* 处理Warp集合 * 处理Warp数组
* *
* <pre>{@code * <pre>{@code
* Warp<String> warp1 = Warp.of(this::select1); * Warp<String> warp1 = Warp.of(this::select1);
@@ -241,11 +241,20 @@ public class RecyclableBatchThreadPoolExecutor {
* List<String> r2 = warp2.get(); * List<String> r2 = warp2.get();
* }</pre> * }</pre>
* *
* @param warps Warp集合 * @param warps Warp数组
* @return Warp集合,此方法返回结果为空的不会被过滤 * @return Warp集合,此方法返回结果为空的不会被过滤
*/ */
public List<Warp<?>> processByWarp(Warp<?>... warps) { public List<Warp<?>> processByWarp(Warp<?>... warps) {
return process(Arrays.asList(warps), 1, Warp::execute); return processByWarp(Arrays.asList(warps));
}
/**
* 处理Warp集合
* @param warps Warp集合
* @return Warp集合,此方法返回结果为空的不会被过滤
*/
public List<Warp<?>> processByWarp(List<Warp<?>> warps) {
return process(warps, 1, Warp::execute);
} }
/** /**