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

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

如何阻止(和加入)由未知數量的 goroutine 提供的通道?

如何阻止(和加入)由未知數量的 goroutine 提供的通道?

Go
慕的地6264312 2021-06-30 17:15:54
我有一個遞歸函數。該函數將根據它獲得的數據使用各種不同的值調用自身,因此遞歸的數量和深度是未知的:每次調用可能會調用自己零次或多次。該函數可以返回任意數量的值。我想通過讓 goroutines 和通道參與進來來并行化它。每次遞歸都inner在自己的 goroutine中運行,并在通道上發回一個值。外部函數處理這些值。func outer(response []int) {  results := make([]int)  resultsChannel := make(chan int)  inner := func(...) {      resultsChannel <- ?some result?;      // Recurse in a new goroutine.      for _, recursionArgument in ?some calculated data? {          go inner(recursionArgument)      }  }  go inner(?initial values?);  for {      result := <- resultsChannel      results = append(results, result)      // HELP! How do I decide when to break?  }  return results}問題在于逃避結果通道循環。由于遞歸的“形狀”(未知的數量和深度),我不能說“在n 個事件后完成”,也不能發送哨兵值。如何檢測所有遞歸何時發生并從 返回outer?有沒有更好的方法來解決這個問題?
查看完整描述

1 回答

?
Helenr

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

您可以使用 async.WaitGroup來管理您生成的 goroutine 的集合:Add(1)在生成每個新 goroutine 之前以及Done每個 goroutine 完成時調用。所以像這樣:


var wg sync.WaitGroup

inner := func(...) {

    ...

    // Recurse in a new goroutine.

    for _, recursionArgument := range ?some calculated data? {

          wg.Add(1)

          go inner(recursionArgument)

    }

    ...

    wg.Done()

}

wg.Add(1)

go inner(?initial values?)

現在等待wg會告訴你所有 goroutine 何時完成。


如果您正在從通道讀取結果,判斷何時沒有更多結果的明顯方法是關閉通道。你可以通過另一個 goroutine 來為我們做到這一點:


go func() {

    wg.Wait()

    close(resultsChannel)

}()

您現在應該能夠簡單地range在resultsChannel閱讀所有的結果。


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

添加回答

舉報

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號

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