当前位置：首页 > 文章列表 > Golang > Go问答 > Golang：在多协程中发送关闭通道错误

Golang：在多协程中发送关闭通道错误

来源：stackoverflow 2024-04-30 09:57:37 0浏览收藏

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《Golang：在多协程中发送关闭通道错误》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

问题内容

我有 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)
}

可以帮助解决什么问题吗？

解决方案

当您在 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:
    }
}

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

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