亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定
已解決430363個問題,去搜搜看,總會有你想問的

在 goroutine 之間發布共享數組

在 goroutine 之間發布共享數組

Go
慕雪6442864 2022-12-13 10:23:40
我正在嘗試解決這個 golang 練習https://github.com/loong/go-concurrency-exercises/tree/master/1-producer-consumer。我想我已經接近解決方案了,但是我遇到了死鎖錯誤davecheney      tweets about golangbeertocode      does not tweet about golangironzeb         tweets about golangbeertocode      tweets about golangvampirewalk666  tweets about golangfatal error: all goroutines are asleep - deadlock!這是我的代碼func producer(stream Stream) (tweets []*Tweet) {    for {        tweet, err := stream.Next()        if err == ErrEOF {            return tweets        }        tweets = append(tweets, tweet)    }}func consumer(tweets []*Tweet) {    for _, t := range tweets {            if t.IsTalkingAboutGo() {            fmt.Println(t.Username, "\ttweets about golang")        } else {            fmt.Println(t.Username, "\tdoes not tweet about golang")        }    }}func main() {    start := time.Now()    stream := GetMockStream()    data := make(chan []*Tweet)    var wg sync.WaitGroup    wg.Add(3)    // Producer    go func() {        tweets := producer(stream)        data <- tweets    }()    // Consumer    go func() {        defer wg.Done()        tweets := <-data        consumer(tweets)    }()    wg.Wait()    fmt.Printf("Process took %s\n", time.Since(start))}你的解決方案在哪里失?。?
查看完整描述

1 回答

?
SMILET

TA貢獻1796條經驗 獲得超4個贊

發生死鎖是因為你傳遞3wg.Add(3),這意味著創建 3 個等待組,但你只需要 1 個。

解決方案是wg.Add(3)wg.Add(1).

在這里查看我的演示代碼


查看完整回答
反對 回復 2022-12-13
  • 1 回答
  • 0 關注
  • 92 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號