需要明确实现接口 GridTask<T，R>

Question

我需要明确实现GridTask的reduce()和map()方法，

如何向这些方法传递参数，

Map<? extends GridJob, GridNode> 
  map(List<GridNode> subgrid, T arg) throws GridException
R reduce(List<GridJobResult> results) throws GridException

具体来说，我需要知道，如何传递/调用reduce方法，或者如果它被隐式调用，那么如何以及传递什么参数给它。

Answer 1

参数是从GridProjection.execute(…)方法传递的。

每当GridJob完成时，它的结果被传递给GridTask.result(…)方法。每当收到GridJobs的所有结果时，就会调用reduce()方法。您还可以通过返回reduce策略表单GridTask.result(…)方法来强制更快地减少。