无法处理 goroutine 死锁

Question

我正在尝试向频道广播一条消息，我只希望它发送 5 条消息。但我总是得到这个错误： 致命错误：所有goroutines都睡着了 - 死锁！我的代码：package mainimport (    "log"    "sync"    broadcast "github.com/dustin/go-broadcast"    "github.com/pwaller/barrier")//Message boradcastedtype Message struct {    y string    x int}var w sync.WaitGroupvar bar barrier.Barrierfunc main() {    b := broadcast.NewBroadcaster(100)    w.Add(1)    go workerOne(b)    d := Message{"message :", 0}    go func() {        for i := 0; i < 5; i++ {            d.x = i            log.Printf("Sending %v", d)            b.Submit(d)        }        <-bar.Barrier()        b.Close()    }()    w.Wait()}func workerOne(b broadcast.Broadcaster) {    ch := make(chan interface{})    b.Register(ch)    for {        v, ok := <-ch        if ok {            log.Printf("workerOne() reading : %v", v)        } else {            log.Printf("i am here")            close(ch)            b.Unregister(ch)            bar.Fall()            w.Done()            return        }    }}我尝试了一切，但它没有抛出条件！在workerOne（）函数中确定以关闭通道并结束等待，但仍然有相同的错误

Answer 1

正如Adrian 在评论中指出的那样barrier，您正在使用的包已被弃用，取而代之的是 Go 包含的context包。你应该context改用。（目前，broadcast您使用的软件包也对您没有任何好处。）

不过，眼前的问题似乎很明显：运行的（单个）goroutineworkerOne从一个通道读取数据，并且只有当通道关闭（因此ok变为false）时，它才会调用bar.Fall()以消除障碍。同时，运行匿名发送者函数的（单个）goroutine：

go func() {

    for i := 0; i < 5; i++ {

        d.x = i

        log.Printf("Sending %v", d)

        b.Submit(d)

    }

    <-bar.Barrier()

    b.Close()

}()

通过包的（非常）简单的消息发布/订阅接口提交五个项目broadcast，然后等待障碍下降。唯一能打破障碍的goroutine——把它想象成唯一可以在这里救你的gopher——是 running workerOne。他现在正在频道接收中等待：

    v, ok := <-ch

你，在你的主 goroutine 中，正在通过你的sync.WaitGroup变量等待：

w.Wait()

运行匿名发送函数的 gopher 正在等待：

    <-bar.Barrier()

谁——这三个在各种 Go 例程中运行或等待的 gopher 中的哪一个——将向匿名发送者中的 gopher 发出信号，v, ok := <-ch应该得到!ok结果？唯一能做到的就是跑的地鼠workerOne，但他被困住了。

该broadcast软件包永远不会为您关闭您的频道。取消注册频道只是将其从广播公司的输出频道中删除，这会使未注册的频道保持打开状态；并且完全有效地关闭广播公司只是取消注册所有频道，再次让它们保持打开状态。因此，如果您希望关闭您的频道，您必须自己在其他地方执行此操作。

或者，您可以修改您的workerOne，使其不依赖于正在关闭的通道。例如，你的变量d有一个x int和一个y string; 你可以选择其中一个或两个，并决定一个字符串值“放下障碍”——也许还有一些特定int的值——意味着“bar.Fall()现在调用”。但是，如果您这样做，那么您从这两个非标准软件包中获得的收益会更少。