Map Reduce 的实现

type Task struct {
	Input         string // Map 阶段的输入文件名
	TaskPhase     Phase // Worker眼中的阶段： Map/Reduce/Exit/Wait
	NReduce       int   // Reduce 的数量
	Index         int   // 该 Task 在 Coordinator中的索引
	Intermediates []string  // Map生成的中间文件名
	Output        string // Reduce 生成的最终输出文件名
}

type Coordinator struct {
	TaskQueue     chan *Task // 待处理的 Task 队列
	TaskMetadatas map[int]*TaskMetadata // Coordinator 维护的 Task 元数据
	Phase         Phase // Coordinator 处于哪个阶段： Map/Reduce/Exit/Wait
	NReduce       int
	InputFiles    []string  // Map 阶段的输入文件名
	Intermediates [][]string 

	mutex sync.Mutex // 用于保护并发安全
}

type TaskMetadata struct {
	TaskStatus TaskStatus 	// Coordinator 关心的 task状态 Unassigned/Working/Finished
	StartTime  time.Time    // 用于防止 Worker 超时
	Task       *Task
}