召唤沉睡的 goroutine 的最佳方法是立即执行 0-N 个 goroutine

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《召唤沉睡的 goroutine 的最佳方法是立即执行 0-N 个 goroutine》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我正在编写一个程序，在其中启动 n 个（n 是命令行参数）工作线程，并且在任何时候，其中 0 到 n-1 个工作线程都可以等待另一个工作线程更新变量。线程等待此事件的最佳方式是什么，以及其中一个线程立即通知所有其他线程事件发生的最佳方式是什么？每个线程都会多次发送该事件。 sync.cond 不合适，因为线程不需要在从睡眠状态唤醒时锁定资源。 sync.waitgroup 不起作用，因为我不知道调用 wg.done() 多少次。

解决方案＃1：我可以使用 sync.mutex 并让线程最终通知其他人获取锁，然后解锁它以通知其他人，但这对于其他人都在争夺锁，而他们都只需要从睡眠状态中跳出来，读取一个变量以查看该特定工人现在是否是主人，然后要么回去睡觉要么开始工作。

解决方案#2：为 sync.waitgroup 创建一个包装器，允许跟踪等待线程的数量，以便我可以调用 wg.add(-numwaitingthreads) 来唤醒它们。弄清楚如何在没有各种竞争条件的情况下对其进行编码，这听起来像是一件令人头痛的事情。

解决方案 #3：在有人提出更好的想法之前，我将使用 n 个通道的列表，并让通知程序非阻塞发送到除其自己的通道之外的所有通道。这真的是最好的方法吗？

更多细节：我给每个工作人员一些独特的信用，并有一个中心变量“哪个信用是下一个要写入输出文件的”。当工作人员完成其正在处理的信用 id 的工作时，它需要执行以下操作：

for centralNextCreditID != creditID {
  wait_for_centralNextCreditID_to_change()
}
saveWorkToFile()
centralNextCreditID++
wake_other_threads_waiting_for_centralNextCreditID_to_change()

正确答案

对我来说，这确实是 sync.Cond 的合适用例。您可以将 *RWMutex.RLocker() 用于 Cond.L，这样一旦发送 Cond.Broadcast()，所有 goroutine 就可以同时获取读锁。

此外，在更改此“谁是主控”变量时，可能值得确保持有写锁以避免竞争条件，这将使 sync.Cond 更适合。

在这种情况下可以使用wg。创建一个计数为 1 的 wg 并将其传递给 N 个 goroutine。将它们设置为 wg.Wait()，除了更新变量的那个。
更新变量的goroutine在更新成功后会调用wg.Done()，从而导致N个goroutine退出等待并开始进一步执行。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《召唤沉睡的 goroutine 的最佳方法是立即执行 0-N 个 goroutine》文章吧，也可关注golang学习网公众号了解相关技术文章。