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

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

Golang for-select 炸毀 CPU

Golang for-select 炸毀 CPU

Go
函數(shù)式編程 2023-07-17 16:23:25
我有一個 grpc 基準測試代碼,它使用一個函數(shù)使用 for-select 子句將數(shù)百個 goroutine 通道合并到一個通道。代碼是這樣的     func (b *B) merge(          ctx context.Context,          nodes ...<-chan *pb.Node,        ) chan *pb.Node {    allNodes := make(chan *pb.Node)    var wg sync.WaitGroup    wg.Add(len(nodes))    for _, n := range nodes {        go func(n <-chan *pb.Node) {            defer wg.Done()            for {                select {                case <-ctx.Done():                    return                case val, ok := <-n:                    if ok {                        allNodes <- val                    }                }            }        }(n)    }    go func() {        wg.Wait()        close(allNodes)    }()    return allNodes}當我在ubuntu 16.04中通過top命令監(jiān)控代碼時,我看到2核服務(wù)器瘋狂旋轉(zhuǎn),CPU使用率超過196%。然后我使用 pprof 包分析我的代碼,它說我的 98% 的 cpu 都在運行這個函數(shù),并且 top 函數(shù)生成如下結(jié)果    flat  flat%   sum%        cum   cum%   1640ms  5.78%  5.78%    27700ms 97.60%  B (*B).merge.func1    5560ms 19.59% 25.37%    22130ms 77.98%  runtime.selectgo     770ms  2.71% 28.08%    11190ms 39.43%  runtime.sellock    2700ms  9.51% 37.60%    10430ms 36.75%  runtime.lock    7710ms 27.17% 64.76%     7710ms 27.17%  runtime.procyield     460ms  1.62% 66.38%     3850ms 13.57%  context.(*cancelCtx).Done    1210ms  4.26% 70.65%     3350ms 11.80%  runtime.selunlock    2700ms  9.51% 80.16%     2900ms 10.22%  sync.(*Mutex).Lock    2110ms  7.43% 87.60%     2140ms  7.54%  runtime.unlock     360ms  1.27% 88.87%      860ms  3.03%  runtime.typedmemclr任何人都可以給我一些關(guān)于如何編寫正確的代碼來合并大量通道的建議,似乎這個 for-select 塊只會讓 cpu 變得瘋狂,而在它后面使用 procyield 這不是一個非常有前途的機制?有沒有辦法控制進程的cpu使用率?
查看完整描述

2 回答

?
阿晨1998

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

似乎最有可能的是nodes在取消上下文之前關(guān)閉參數(shù)中傳遞的通道。這會將您的for循環(huán)變成緊密循環(huán),從而消耗所有可用的 CPU。ok由于通道一旦關(guān)閉就無法重新打開,因此一旦為 false,您就可以安全地從 goroutine 返回,這應(yīng)該可以解決該問題:


    go func(n <-chan *pb.Node) {

        defer wg.Done()

        for {

            select {

            case <-ctx.Done():

                return

            case val, ok := <-n:

                if !ok {

                    return

                }

                allNodes <- val

            }

        }

    }(n)


查看完整回答
反對 回復 2023-07-17
?
叮當貓咪

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

封閉的 chan 不會阻塞 - 請參閱https://dave.cheney.net/2013/04/30/curious-channels


關(guān)閉后將你的 chan 設(shè)置為零。


  case val, ok := <-n:

    if ok {

      allNodes <- val

    } else {

      n = nil

    }

然后 select 將阻塞,僅等待完成消息。


查看完整回答
反對 回復 2023-07-17
  • 2 回答
  • 0 關(guān)注
  • 192 瀏覽
慕課專欄
更多

添加回答

舉報

0/150
提交
取消
微信客服

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

幫助反饋 APP下載

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

公眾號

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