AsyncForeach
对于管道中的每个记录，异步运行一些操作。
public GearsBuilder<T> asyncForeach(
gears.operations.AsyncForeachOperation<T> foreach)
asyncForeach 函数允许您使用 GearsFuture 对象来定义一组操作，并为管道中的每个记录异步运行这些操作。
参数
| 名称 | 类型 | 描述 |
|---|---|---|
| foreach | AsyncForeachOperation |
要为每个记录运行的操作集 |
返回值
返回一个具有新模板类型的 GearsBuilder 对象。
示例
GearsBuilder.CreateGearsBuilder(reader).map(r->r.getKey()).
asyncForeach(r->{
GearsFuture<Serializable> f = new GearsFuture<Serializable>();
new Thread(new Runnable() {
@Override
public void run() {
try {
Thread.sleep(1);
f.setResult(r);
} catch (Exception e) {
e.printStackTrace();
}
}
}).start();
return f;
});