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

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