Golang :在多 goroutines 中发送闭合通道错误

Question

我有 3 个通道一起获取数据。我的代码第一次完美运行，但是之后我发送另一个数据时，出现错误：在封闭通道上发送。在 func FillNotCheckedDeliveryCh 那行我关闭了通道。如果我不关闭它，应用程序停止并且不继续。

func main() {
    receiveBulkIdsCh := make(chan int64, 100)
    NotCheckedDeliveryCh := make(chan CommonType.BasicRequestParameters, 100)
    ResultCh := make(chan CommonType.MessageStateResult, 100)
    var wg sync.WaitGroup
    wg.Add(4)
    /* Every BulkIds that receive from queue , save in  receiveBulkIdsChan channel*/
    go func() {
        defer wg.Done()
        PopQueue(receiveBulkIdsCh)
    }()
    go func() {
        defer wg.Done()
        for BulkId := range receiveBulkIdsCh {
            FillNotCheckedDeliveryCh(data, NotCheckedDeliveryCh)
        }
    }()
    go func() {
        defer wg.Done()
        for item := range NotCheckedDeliveryCh {
            for msgStatus := range DoFuncGetMessageState(item) {
                ResultCh <- msgStatus
            }
            close(ResultCh)
        }
    }()
    go func() {
        defer wg.Done()
        for Result := range ResultCh {
            ReadResultCh(Result)
        }
    }()
    wg.Wait()
}
func FillNotCheckedDeliveryCh(data IntegrateRowsFields, ch chan<- CommonType.BasicRequestParameters) {
    ch <- PackerForNotFinishedCh(data)
    defer close(ch)
}

可以帮助出了什么问题？

Answer 1

当你在 Go 中使用频道时，发送者应该关闭频道。因为这表示不会再通过通道发送数据。

在您的代码中，接收器正在关闭它。只需在此处打开通道并删除那里的close(ch)即可。

func FillNotCheckedDeliveryCh(data IntegrateRowsFields, ch chan<- CommonType.BasicRequestParameters) {
    ch <- PackerForNotFinishedCh(data)
    defer close(ch)
}

如果该部分有东西阻塞，您可以使用select：

func FillNotCheckedDeliveryCh(data IntegrateRowsFields, ch chan<- CommonType.BasicRequestParameters) {  
    select {
      case ch <- PackerForNotFinishedCh(data):
      default:
    }
}

Answer 2

关闭接收端的通道，然后尝试在同一通道上发送会出错。更好的方法是仅在通道上发送所有值后关闭 go 例程之外的通道。

等待所有 go 例程完成后关闭通道。

wg.Wait()
close(ch)

当通道上没有更多要发送的值时，始终关闭通道。

接收器可以通过分配 接收表达式的第二个参数：之后

v, ok := <-ch

在您的情况下，您也可以使用 ok 在接收器端检查通道中是否有更多值或通道是否已关闭。

频道不像文件;您通常不需要关闭它们。 仅当必须告诉接收方没有时，才需要关闭 更多值即将到来，例如终止范围循环。

Go 游乐场示例，用于在不关闭通道和范围时生成错误。

用于在发送所有值时关闭通道的游乐场示例。