第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

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

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

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

Go
慕的地6264312 2021-06-30 17:15:54
我有一個遞歸函數(shù)。該函數(shù)將根據(jù)它獲得的數(shù)據(jù)使用各種不同的值調(diào)用自身,因此遞歸的數(shù)量和深度是未知的:每次調(diào)用可能會調(diào)用自己零次或多次。該函數(shù)可以返回任意數(shù)量的值。我想通過讓 goroutines 和通道參與進來來并行化它。每次遞歸都inner在自己的 goroutine中運行,并在通道上發(fā)回一個值。外部函數(shù)處理這些值。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}問題在于逃避結(jié)果通道循環(huán)。由于遞歸的“形狀”(未知的數(shù)量和深度),我不能說“在n 個事件后完成”,也不能發(fā)送哨兵值。如何檢測所有遞歸何時發(fā)生并從 返回outer?有沒有更好的方法來解決這個問題?
查看完整描述

1 回答

?
Helenr

TA貢獻1780條經(jīng)驗 獲得超4個贊

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


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

現(xiàn)在等待wg會告訴你所有 goroutine 何時完成。


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


go func() {

    wg.Wait()

    close(resultsChannel)

}()

您現(xiàn)在應(yīng)該能夠簡單地range在resultsChannel閱讀所有的結(jié)果。


查看完整回答
反對 回復(fù) 2021-07-12
  • 1 回答
  • 0 關(guān)注
  • 219 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

購課補貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動學(xué)習(xí)伙伴

公眾號

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號