distributed-computing
distributed-computing copied to clipboard
distributed 模式下不能运行
感谢你提供的示例,distributed模式下不能运行成功,调试之后发现有三处需要修改:
- 入口处wc.go需要执行mapreduce.RunWorker方法,否则程序不执行。
- Master和Worker对外曝出的方法没有按照RPC的方法格式,如Master的Wait()、CleanupFiles()、Lock()和Unlock()方法。
- Worker的net.Listener监听Accept()没有Close(),导致程序一直处于阻塞状态,不能正常结束。 PS:从你的代码中学到了更多东西,Thanks!