douli1306 2018-08-08 07:32
浏览 136
已采纳

Golang:在多个goroutine中发送关闭通道错误

I have 3 channels that get data from together . My code run for first time perfect but when after that I send another data , there is error : send on closed channel.In func FillNotCheckedDeliveryCh that line I closed channel .If I do not close it app stopped and not continue.

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

can help what's wrong ?

  • 写回答

2条回答 默认 最新

  • douya1248 2018-08-08 07:54
    关注

    When you work with channels in Go always the sender should close the channel. Because that signals that no more data will be send over the channel.

    In your code the receiver is closing it. Just leave the channel here opened and remove the close(ch) there.

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

    If something is blocking at that part you could use select:

    func FillNotCheckedDeliveryCh(data IntegrateRowsFields, ch chan<- CommonType.BasicRequestParameters) {  
        select {
          case ch <- PackerForNotFinishedCh(data):
          default:
        }
    }
    
    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
  • dquv73115 2018-08-08 09:17
    关注

    Closing the channels on the receiver side, and then trying to send on the same channel gives you the error. Better is to close the channel outside the go routine only after all values are send on the channels.

    Close the channel after waiting for all go routines to be finished.

    wg.Wait()
    close(ch)
    

    Always close the channel when there are no more values to send on that channel.

    Receivers can test whether a channel has been closed by assigning a second parameter to the receive expression: after

    v, ok := <-ch
    

    In your case too you can check on the receiver side by using ok if there are more values in the channel or if it is closed.

    Channels aren't like files; you don't usually need to close them. Closing is only necessary when the receiver must be told there are no more values coming, such as to terminate a range loop.

    Go playground example for generating the error when not closing a channel and range over it.

    Playground example for closing the channels when all values are send.

    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥100 webapi的部署(标签-服务器)
  • ¥20 怎么加快手机软件内部计时的时间(关键词-日期时间)
  • ¥15 C语言除0问题的检测方法
  • ¥15 为什么四分管的内径有的是16mm有的15mm,四分不应该是12.7mm吗
  • ¥15 macos13下 ios交叉编译的问题
  • ¥15 bgz压缩文件怎么打开
  • ¥15 封装dll(引入了pcl的点云设计库)
  • ¥30 关于#开发语言#的问题:我需要在抄板的基础上再抄板抄程序,根据RDA8851CM基础上开发
  • ¥15 oracle 多个括号,怎么删除指定的括号及里面的内容?
  • ¥15 小新14API2019想用bios调风扇