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

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

優(yōu)雅地關(guān)閉通道而不是在關(guān)閉的通道上發(fā)送

優(yōu)雅地關(guān)閉通道而不是在關(guān)閉的通道上發(fā)送

Go
浮云間 2023-03-15 15:17:02
我是Golang并發(fā)的新手,一直在努力理解下面提到的這段代碼。我目睹了一些我無法解釋為什么會發(fā)生的事情:for i <= 100000 {在 main 函數(shù)中 使用小于等于 100000 的 i 時,它有時會為 nResults 和 countWrites 打印不同的值(在最后兩個語句中)fmt.Printf("number of result writes %d\n", nResults) fmt.Printf("Number of job writes %d\n", jobWrites)當(dāng)我使用超過 1000000 時,它給出panic: send on closed channel我如何確保發(fā)送給作業(yè)的值不在關(guān)閉的通道上,并且稍后在結(jié)果中收到所有值后我們可以關(guān)閉通道而不會出現(xiàn)死鎖?package mainimport (    "fmt"    "sync")func worker(wg *sync.WaitGroup, id int, jobs <-chan int, results chan<- int, countWrites *int64) {    defer wg.Done()    for j := range jobs {        *countWrites += 1        go func(j int) {            if j%2 == 0 {                results <- j * 2            } else {                results <- j            }        }(j)    }}func main() {    wg := &sync.WaitGroup{}    jobs := make(chan int)    results := make(chan int)    var i int = 1    var jobWrites int64 = 0    for i <= 10000000 {        go func(j int) {            if j%2 == 0 {                i += 99                j += 99            }            jobWrites += 1            jobs <- j        }(i)        i += 1    }    var nResults int64 = 0    for w := 1; w < 1000; w++ {        wg.Add(1)        go worker(wg, w, jobs, results, &nResults)    }    close(jobs)    wg.Wait()    var sum int32 = 0    var count int64 = 0    for r := range results {        count += 1        sum += int32(r)        if count == nResults {            close(results)        }    }    fmt.Println(sum)    fmt.Printf("number of result writes %d\n", nResults)    fmt.Printf("Number of job writes %d\n", jobWrites)}
查看完整描述

1 回答

?
慕村9548890

TA貢獻(xiàn)1884條經(jīng)驗 獲得超4個贊

您的代碼中有很多問題。

在關(guān)閉的頻道上發(fā)送

使用 Go 通道的一個一般原則是

不要從接收端關(guān)閉通道,如果通道有多個并發(fā)發(fā)送者則不要關(guān)閉通道

您的解決方案很簡單:不要有多個并發(fā)發(fā)件人,然后您可以從發(fā)件人端關(guān)閉頻道。

與其為添加到通道的每個作業(yè)啟動數(shù)百萬個單獨的 goroutine,不如運行一個執(zhí)行整個循環(huán)的 goroutine 以將所有作業(yè)添加到通道。并在循環(huán)后關(guān)閉通道。工作人員將盡可能快地使用通道。

通過修改多個 goroutine 中的共享變量來進(jìn)行數(shù)據(jù)競爭

您在不采取特殊步驟的情況下修改兩個共享變量:

  1. nResults,您將其傳遞給countWrites *int64工作人員中的。

  2. ijobs在寫入作業(yè)通道的循環(huán)中:您從多個 goroutines 向它添加 99,這使得它無法預(yù)測您實際向通道寫入了多少值

要解決 1,有很多選項,包括使用sync.Mutex.?但是,由于您只是添加它,所以最簡單的解決方案是使用atomic.AddInt64(countWrites, 1)而不是*countWrites += 1

要解決 2,不要在每次寫入通道時使用一個 goroutine,而是在整個循環(huán)中使用一個 goroutine(見上文)


查看完整回答
反對 回復(fù) 2023-03-15
  • 1 回答
  • 0 關(guān)注
  • 96 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號

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