mapreduce

mapreduce copied to clipboard

`mapreduce.Finish`中嵌套使用`mapreduce.MapReduce`会导致`Finish`变成非阻塞操作

1

嵌套的`MapReduce`的`reducer`中如果不调用`writer.Write`方法，会产生一个`ErrReduceNoOutput`错误，Finish 中 worker 返回异常会直接结束 Finish 调用，但是`Finish`中调用的`MapReduceVoid`会吞掉`ErrReduceNoOutput`错误返回一个 nil，从最后结果看是没有异常的成功调用，实际其他的 `worker` 都还在异步运行 例如下面这样的调用： ```golang func main(){ err := mapreduce.Finish(func() error { return worker1() }, func() error { val, err := mapreduce.MapReduce(func(source chan

lujin123

to2false