Package | Description |
---|---|
cn.hutool.core.thread |
提供线程及高并发封装,入口为ThreadUtil
|
Modifier and Type | Method and Description |
---|---|
RecyclableBatchThreadPoolExecutor.Warp<R> |
RecyclableBatchThreadPoolExecutor.Warp.execute()
执行
|
static <R> RecyclableBatchThreadPoolExecutor.Warp<R> |
RecyclableBatchThreadPoolExecutor.Warp.of(Supplier<R> supplier)
创建Warp
|
Modifier and Type | Method and Description |
---|---|
List<RecyclableBatchThreadPoolExecutor.Warp<?>> |
RecyclableBatchThreadPoolExecutor.processByWarp(List<RecyclableBatchThreadPoolExecutor.Warp<?>> warps)
处理Warp集合
|
List<RecyclableBatchThreadPoolExecutor.Warp<?>> |
RecyclableBatchThreadPoolExecutor.processByWarp(RecyclableBatchThreadPoolExecutor.Warp<?>... warps)
处理Warp数组
Warp<String> warp1 = Warp.of(this::select1);
Warp<List<String>> warp2 = Warp.of(this::select2);
executor.processByWarp(warp1, warp2);
String r1 = warp1.get();
List<String> r2 = warp2.get();
|
Modifier and Type | Method and Description |
---|---|
List<RecyclableBatchThreadPoolExecutor.Warp<?>> |
RecyclableBatchThreadPoolExecutor.processByWarp(RecyclableBatchThreadPoolExecutor.Warp<?>... warps)
处理Warp数组
Warp<String> warp1 = Warp.of(this::select1);
Warp<List<String>> warp2 = Warp.of(this::select2);
executor.processByWarp(warp1, warp2);
String r1 = warp1.get();
List<String> r2 = warp2.get();
|
Modifier and Type | Method and Description |
---|---|
List<RecyclableBatchThreadPoolExecutor.Warp<?>> |
RecyclableBatchThreadPoolExecutor.processByWarp(List<RecyclableBatchThreadPoolExecutor.Warp<?>> warps)
处理Warp集合
|
Copyright © 2025. All rights reserved.