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;
});