同时顺序执行任务

一分耕耘，一分收获！既然都打开这篇《同时顺序执行任务》，就坚持看下去，学下去吧！本文主要会给大家讲到等等知识点，如果大家对本文有好的建议或者看到有不足之处，非常欢迎大家积极提出！在后续文章我会继续更新Golang相关的内容，希望对大家都有所帮助！

“什么？”你会问，“这个标题没有任何意义。”

考虑以下因素： 具有不同 id 的作业可以异步处理，但具有相同 id 的作业应同步处理并按队列中的顺序处理。

我当前的实现创建了一个 go 例程来处理每个特定 id 的作业，看起来像这样：

func FanOut() chan<- *Job {
    channel := make(chan *Job)
    routines = make(map[string]chan<- *Job)
    go func() {
        for j := range channel {
            r, found := routines[j.id]
            if !found {
                r = Routine()
                routines[j.id] = r
            }
            r <- j
        }
    }()
    return channel
}

这似乎工作得很好（在当前的测试中），但是创建数千个 go 例程可能不是最好的方法？此外，除非使用缓冲通道，否则扇出代码会阻塞。

我正在考虑使用sync.mutex的集合，而不是go例程的集合（上面）。这个想法是拥有一个 go 例程池，它必须首先在与作业 id 相对应的互斥锁上建立锁定。

现有的 go 模式是否适合处理这些要求？

有更好的方法吗？

解决方案

为每个 ID 创建一个通道 - 可能是通道切片或地图（按 ID 索引）。每个通道都有一个 go-routine，按顺序处理该 ID 的作业。简单。

我不会担心创建太多的 go 例程。而且我不会使用互斥体 - 无需深入了解使用通道和 go 例程的太多细节，允许每个作业一次仅由一个 go 例程处理，并避免数据争用的可能性。

顺便说一句，我只是将其添加为答案，因为我还不允许添加评论（还？）。

今天关于《同时顺序执行任务》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！