无法处理 goroutine 死锁

Question

我正在尝试向某个频道广播一条消息，我只想让它发送 5 条消息。但我总是收到这个错误： 致命错误：所有 goroutine 都在睡觉 - 死锁！

我的代码：

package main

import (

    "log"

    "sync"

    broadcast "github.com/dustin/go-broadcast"

    "github.com/pwaller/barrier"

)

//Message boradcasted

type Message struct {

    y string

    x int

}

var w sync.WaitGroup

var bar barrier.Barrier

func 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

        }

    }

}

输出 ：

2019/12/26 20:34:11 Sending {message : 0}

2019/12/26 20:34:11 Sending {message : 1}

2019/12/26 20:34:11 Sending {message : 2}

2019/12/26 20:34:11 Sending {message : 3}

2019/12/26 20:34:11 Sending {message : 4}

2019/12/26 20:34:11 workerOne() reading : {message : 0}

2019/12/26 20:34:11 workerOne() reading : {message : 1}

2019/12/26 20:34:11 workerOne() reading : {message : 2}

2019/12/26 20:34:11 workerOne() reading : {message : 3}

2019/12/26 20:34:11 workerOne() reading : {message : 4}

fatal error: all goroutines are asleep - deadlock!

我尝试了一切，但它不会在workerOne()函数中抛出条件！ok来关闭通道并结束等待，但仍然有相同的错误

Answer 1

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（把它想象成唯一能在这里拯救你的地鼠workerOne）就是正在运行的 goroutine 。他现在正在频道接收中等待：    v, ok := <-ch您在主 Goroutine 中正在通过sync.WaitGroup变量等待：w.Wait()运行匿名发送函数的地鼠正在等待：    <-bar.Barrier()谁——在不同的 Go 例程中运行或等待的三个地鼠中的哪一个——将向匿名发送者中的地鼠发出信号，应该v, ok := <-ch得到!ok结果？唯一能做到的就是地鼠奔跑workerOne，但他被困住了。该broadcast软件包永远不会为您关闭您的频道。取消注册频道只是将其从广播公司的输出频道中删除，从而使未注册的频道保持开放状态；完全有效地关闭广播公司只会注销所有频道，再次让它们保持开放状态。因此，如果您希望关闭自己的频道，则必须自己在其他地方执行此操作。或者，您可以修改您的设置workerOne，使其不依赖于关闭的通道。例如，您的变量d有 anx int和 a y string; 您可以选择其中一个或两个，并确定读取“drop thebarrier”的字符串值（可能int还具有某些特定值）意味着“bar.Fall()立即调用”。如果您这样做，您从这两个非标准包中获得的收益会更少。