Question

我比较新要去和有一些麻烦与一些同时代码:

出于某种原因,其他区块执行两次,而程序恐慌则带有以下信息: panic:关闭闭路通道 ,因为 expactedCh 第一次已经关闭。

func (ex Extractor) Extract(pageCh chan *types.ScrapedData, extractedCh chan *types.ScrapedData) {
    log.Info().Msg("Extracting data...")

    var wg sync.WaitGroup

    for {
        page, more := <-pageCh
        if more {
            wg.Add(1)

            go func() {
                defer wg.Done()
                worker, err := ex.getWorker(page)
                if err != nil {
                    log.Error().Err(err).Msg("Error creating worker")
                } else {
                    worker.Extract(extractedCh)
                }
            }()

        } else {
            log.Info().Msg("WebPage channel closed: waiting for waitgroup")
            wg.Wait()

            log.Info().Msg("WaitGroup finished closed -- closing extractedCh")
            close(extractedCh)
        }

    }

}

抽取函数只以一个运行程序运行 - 所以我不知道为什么其它块执行两次, 并试图关闭已经关闭的 < code> Exctracted Ch 。

答案是什么:我是要重组我的代码, 还是简单地检查频道关闭前是否关闭?

Answer 1

其它区块第二次执行, 因为当 < code> pageCh 关闭时, 其它区块不会打破循环。通过添加一个 < code> return 语句来修正其它区块的结尾。最好还是重写这样的代码 :

func (ex Extractor) Extract(pageCh chan *types.ScrapedData, extractedCh chan *types.ScrapedData) {
    log.Info().Msg("Extracting data...")
    var wg sync.WaitGroup
    for page := range pageCh {
        wg.Add(1)
        page := page // delete this line if compiling for Go 1.22 or later
        go func() {
            defer wg.Done()
            worker, err := ex.getWorker(page)
            if err != nil {
                log.Error().Err(err).Msg("Error creating worker")
            } else {
                worker.Extract(extractedCh)
            }
        }()
    }
    log.Info().Msg("WebPage channel closed: waiting for waitgroup")
    wg.Wait()
    log.Info().Msg("WaitGroup finished closed -- closing extractedCh")
    close(extractedCh)
}

pageCh 关闭时循环退出。

可能会造成混乱的一件事就是这条线:

    page, more := <-pageCh

频道接收的第二个返回值表示“ 收到一个值 ”, 而不是“ 更多预期值 ” 。如果第二个返回值是 < code> false , 意思是“ 未收到值 ”, 那么在频道上接收的返回值将永远返回第二个返回值中的 < code> false 。

友情链接