当前位置： > > > > 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例程完成后关闭通道。

wg.wait()
close(ch)

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

v, ok := <-ch

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

用于在未关闭通道及其范围时生成错误。

用于在发送所有值时关闭通道。

今天关于《Golang：在多协程中发送关闭通道错误》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于的内容请关注米云公众号！