色哟哟视频在线观看-色哟哟视频在线-色哟哟欧美15最新在线-色哟哟免费在线观看-国产l精品国产亚洲区在线观看-国产l精品国产亚洲区久久

0
  • 聊天消息
  • 系統消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術視頻
  • 寫文章/發帖/加入社區
會員中心
电子发烧友
开通电子发烧友VIP会员 尊享10大特权
海量资料免费下载
精品直播免费看
优质内容免费畅学
课程9折专享价
創作中心

完善資料讓更多小伙伴認識你,還能領取20積分哦,立即完善>

3天內不再提示

Go timer的工作原理是什么?Go timer是如何被調度的?

冬至子 ? 來源:HHFCodeRv ? 作者:haohongfan ? 2023-07-17 15:16 ? 次閱讀
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

定時器不管是業務開發,還是基礎架構開發,都是繞不過去的存在,由此可見定時器的重要程度。

我們不管用 NewTimer, timer.After,還是 timer.AfterFun 來初始化一個 timer, 這個 timer 最終都會加入到一個全局 timer 堆中,由 Go runtime 統一管理。

全局的 timer 堆也經歷過三個階段的重要升級。

  • Go 1.9 版本之前,所有的計時器由全局唯一的四叉堆維護,協程間競爭激烈。
  • Go 1.10 - 1.13,全局使用 64 個四叉堆維護全部的計時器,沒有本質解決 1.9 版本之前的問題
  • Go 1.14 版本之后,每個 P 單獨維護一個四叉堆。

Go 1.14 以后的 timer 性能得到了質的飛升,不過伴隨而來的是 timer 成了 Go 里面最復雜、最難梳理的數據結構。本文不會詳細分析每一個細節,我們從大體來了解 Go timer 的工作原理。

1. 使用場景

Go timer 在我們代碼中會經常遇到。

場景1:RPC 調用的防超時處理(下面代碼節選 dubbogo)

func (c *Client) Request(request *remoting.Request, timeout time.Duration, response *remoting.PendingResponse) error {
    _, session, err := c.selectSession(c.addr)
    // .. 省略
    if totalLen, sendLen, err = c.transfer(session, request, timeout); err != nil {
        if sendLen != 0 && totalLen != sendLen {
          // .. 省略
        }
        return perrors.WithStack(err)
    }

    // .. 省略
    select {
    case < -getty.GetTimeWheel().After(timeout):
        return perrors.WithStack(errClientReadTimeout)
    case < -response.Done:
        err = response.Err
    }
    return perrors.WithStack(err)
}

場景2:Context 的超時處理

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
    defer cancel()
    go doSomething()
    
    select {
    case < -ctx.Done():
        fmt.Println("main", ctx.Err())
    }
}

2. 圖解源碼

2.1 四叉堆原理

timer 的全局堆是一個四叉堆,特別是 Go 1.14 之后每個 P 都會維護著一個四叉堆,減少了 Goroutine 之間的并發問題,提升了 timer 了性能。

四叉堆其實就是四叉樹,Go timer 是如何維護四叉堆的呢?

  • Go runtime 調度 timer 時,觸發時間更早的 timer,要減少其查詢次數,盡快被觸發。所以四叉樹的父節點的觸發時間是一定小于子節點的。
  • 四叉樹顧名思義最多有四個子節點,為了兼顧四叉樹插、刪除、重排速度,所以四個兄弟節點間并不要求其按觸發早晚排序。

這里用兩張動圖簡單演示下 timer 的插入和刪除

把 timer 插入堆

圖片

把 timer 從堆中刪除

圖片

2.2 timer 是如何被調度的?

  • 調用 NewTimer,timer.After, timer.AfterFunc 生產 timer, 加入對應的 P 的堆上。
  • 調用 timer.Stop, timer.Reset 改變對應的 timer 的狀態。
  • GMP 在調度周期內中會調用 checkTimers ,遍歷該 P 的 timer 堆上的元素,根據對應 timer 的狀態執行真的操作。

圖片

2.3 timer 是如何加入到 timer 堆上的?

把 timer 加入調度總共有下面幾種方式:

  • 通過 NewTimer, time.After, timer.AfterFunc 初始化 timer 后,相關 timer 就會被放入到對應 p 的 timer 堆上。
  • timer 已經被標記為 timerRemoved,調用了 timer.Reset(d),這個 timer 也會重新被加入到 p 的 timer 堆上
  • timer 還沒到需要被執行的時間,被調用了 timer.Reset(d),這個 timer 會被 GMP 調度探測到,先將該 timer 從 timer 堆上刪除,然后重新加入到 timer 堆上
  • STW 時,runtime 會釋放不再使用的 p 的資源,p.destroy()->timer.moveTimers,將不再被使用的 p 的 timers 上有效的 timer(狀態是:timerWaiting,timerModifiedEarlier,timerModifiedLater) 都重新加入到一個新的 p 的 timer 上

2.4 Reset 時 timer 是如何被操作的?

Reset 的目的是把 timer 重新加入到 timer 堆中,重新等待被觸發。不過分為兩種情況:

  • 被標記為 timerRemoved 的 timer,這種 timer 是已經從 timer 堆上刪除了,但會重新設置被觸發時間,加入到 timer 堆中
  • 等待被觸發的 timer,在 Reset 函數中只會修改其觸發時間和狀態(timerModifiedEarlier或timerModifiedLater)。這個被修改狀態的 timer 也同樣會被重新加入到 timer堆上,不過是由 GMP 觸發的,由 checkTimers 調用 adjusttimers 或者 runtimer 來執行的。

圖片

2.5 Stop 時 timer 是如何被操作的?

time.Stop 為了讓 timer 停止,不再被觸發,也就是從 timer 堆上刪除。不過 timer.Stop 并不會真正的從 p 的 timer 堆上刪除 timer,只會將 timer 的狀態修改為 timerDeleted。然后等待 GMP 觸發的 adjusttimers 或者 runtimer 來執行。

真正刪除 timer 的函數有兩個 dodeltimer,dodeltimer0。

圖片

2.6 Timer 是如何被真正執行的?

timer 的真正執行者是 GMP。GMP 會在每個調度周期內,通過 runtime.checkTimers 調用 timer.runtimer(). timer.runtimer 會檢查該 p 的 timer 堆上的所有 timer,判斷這些 timer 是否能被觸發。

如果該 timer 能夠被觸發,會通過回調函數 sendTime 給 Timer 的 channel C 發一個當前時間,告訴我們這個 timer 已經被觸發了。

如果是 ticker 的話,被觸發后,會計算下一次要觸發的時間,重新將 timer 加入 timer 堆中。

圖片

3. Timer 使用中的坑

確實 timer 是我們開發中比較常用的工具,但是 timer 也是最容易導致內存泄露,CPU 狂飆的殺手之一。

不過仔細分析可以發現,其實能夠造成問題就兩個方面:

  • 錯誤創建很多的 timer,導致資源浪費
  • 由于 Stop 時不會主動關閉 C,導致程序阻塞

3.1 錯誤創建很多 timer,導致資源浪費

func main() {
    for {
        // xxx 一些操作
        timeout := time.After(30 * time.Second)
        select {
        case < - someDone:
            // do something
        case < -timeout:
            return
        }
    }
}

上面這段代碼是造成 timer 異常的最常見的寫法,也是我們最容易忽略的寫法。

造成問題的原因其實也很簡單,因為 timer.After 底層是調用的 timer.NewTimer,NewTimer 生成 timer 后,會將 timer 放入到全局的 timer 堆中。

for 會創建出來數以萬計的 timer 放入到 timer 堆中,導致機器內存暴漲,同時不管 GMP 周期 checkTimers,還是插入新的 timer 都會瘋狂遍歷 timer 堆,導致 CPU 異常。

要注意的是,不只 time.After 會生成 timer, NewTimer,time.AfterFunc 同樣也會生成 timer 加入到 timer 中,也都要防止循環調用。

解決辦法: 使用 time.Reset 重置 timer,重復利用 timer。

我們已經知道 time.Reset 會重新設置 timer 的觸發時間,然后將 timer 重新加入到 timer 堆中,等待被觸發調用。

func main() {
    timer := time.NewTimer(time.Second * 5)    
    for {
        timer.Reset(time.Second * 5)

        select {
        case < - someDone:
            // do something
        case < -timer.C:
            return
        }
    }
}

3.2 程序阻塞,造成內存或者 goroutine 泄露

func main() {
    timer1 := time.NewTimer(2 * time.Second)
    < -timer1.C
    println("done")
}

上面的代碼可以看出來,只有等待 timer 超時 "done" 才會輸出,原理很簡單:程序阻塞在 <-timer1.C 上,一直等待 timer 被觸發時,回調函數 time.sendTime 才會發送一個當前時間到 timer1.C 上,程序才能繼續往下執行。

不過使用 timer.Stop 的時候就要特別注意了,比如:

func main() {
    timer1 := time.NewTimer(2 * time.Second)
    go func() {
        timer1.Stop()
    }()
    < -timer1.C

    println("done")
}

程序就會一直死鎖了,因為 timer1.Stop 并不會關閉 channel C,使程序一直阻塞在 timer1.C 上。

上面這個例子過于簡單了,試想下如果 <- timer1.C 是阻塞在子協程中,timer 被的 Stop 方法被調用,那么子協程可能就會被永遠的阻塞在那里,造成 goroutine 泄露,內存泄露。

Stop 的正確的使用方式:

func main() {
    timer1 := time.NewTimer(2 * time.Second)
    go func() {
        if !timer1.Stop() {
            < -timer1.C
        }
    }()

    select {
    case < -timer1.C:
        fmt.Println("expired")
    default:
    }
    println("done")
}
聲明:本文內容及配圖由入駐作者撰寫或者入駐合作網站授權轉載。文章觀點僅代表作者本人,不代表電子發燒友網立場。文章及其配圖僅供工程師學習之用,如有內容侵權或者其他違規問題,請聯系本站處理。 舉報投訴
  • 處理器
    +關注

    關注

    68

    文章

    19916

    瀏覽量

    235592
  • GMP
    GMP
    +關注

    關注

    0

    文章

    11

    瀏覽量

    9107
  • RPC
    RPC
    +關注

    關注

    0

    文章

    111

    瀏覽量

    11910
  • 觸發器
    +關注

    關注

    14

    文章

    2039

    瀏覽量

    62182
  • 狀態機
    +關注

    關注

    2

    文章

    493

    瀏覽量

    28277
收藏 0人收藏
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

    評論

    相關推薦
    熱點推薦

    NanoSync Timer 介紹

    Timer
    橙群微電子
    發布于 :2023年11月02日 10:07:13

    go語言能做什么工作?

    Go語言主要用作服務器端開發,其定位是用來開發“大型軟件”的,適合于很多程序員一起開發大型軟件,并且開發周期長,支持云計算的網絡服務。Go語言能夠讓程序員快速開發,并且在軟件不斷的增長過程中,它能
    發表于 03-22 15:03

    s3c2410 Timer工作原理

    Width Modulation—— PWM(脈寬調制 )。Timer4是一個內部定時器(internal timer),他沒有輸出引腳(output pins)。 下面是Timer工作原
    發表于 08-20 06:21

    16F676怎么重置GO?

    timer// GO = TRUE; // Start ADCif(second) // One second timer{second--;if(second == 0){ if(time
    發表于 04-10 14:58

    555 Timer PRO and Lite

    555 Timer PRO provides an array of design wizards, circuit blocks and information panels
    發表于 05-09 19:06 ?86次下載

    通用定時器(Timer)

    1、Timer2 和 Timer3。它們的用法是相同的:每 個 Timer 模塊都可以配置為一個 32 位定時器或一個 32 位 RTC 定時器;也可以拆分為兩個 16 位的定時/計數器 TimerA 和 TimerB,它們
    發表于 01-13 16:34 ?24次下載

    基于8051的Proteus仿真-TIMER0與TIMER1控制

    基于8051的Proteus仿真-TIMER0與TIMER1控制條形LED
    發表于 09-01 23:32 ?15次下載

    Firefly關于TIMER 使用簡介

    ~pmutimer1), 我們主要用到的是Timers(timer0-timer11)時鐘頻率為24MHZ ,工作模式有 free-running 和 user-defined count 模式
    的頭像 發表于 11-20 11:17 ?1650次閱讀
    Firefly關于<b class='flag-5'>TIMER</b> 使用簡介

    fireflyAIO-3399C主板TIMER介紹

    ~pmutimer1), 我們主要用到的是Timers(timer0-timer11)時鐘頻率為24MHZ ,工作模式有 free-running 和 user-defined count 模式
    的頭像 發表于 12-09 16:26 ?1796次閱讀
    fireflyAIO-3399C主板<b class='flag-5'>TIMER</b>介紹

    fireflyAIO-3399J主板TIMER使用簡介

    ~pmutimer1), 我們主要用到的是Timers(timer0-timer11)時鐘頻率為24MHZ ,工作模式有 free-running 和 user-defined count 模式
    的頭像 發表于 12-24 10:25 ?1938次閱讀
    fireflyAIO-3399J主板<b class='flag-5'>TIMER</b>使用簡介

    使用單片機實現TIMER0和TIMER1與TIMER2實現外部信號計數與顯示的程序

    本文檔的主要內容詳細介紹的是使用單片機實現TIMER0和TIMER1與TIMER2實現外部信號計數與顯示的C語言程序免費下載。
    發表于 03-26 16:42 ?26次下載

    詳解剖析Go語言調度模型的設計

    golang的MPG調度模型是保障Go語言效率高的一個重要特性,本文詳細介紹了Go語言調度模型的設計。 前言 Please remember that at the end of th
    的頭像 發表于 07-26 10:12 ?2404次閱讀
    詳解剖析<b class='flag-5'>Go</b>語言<b class='flag-5'>調度</b>模型的設計

    vim-go Vim的Go開發插件

    ./oschina_soft/vim-go.zip
    發表于 05-24 09:42 ?1次下載
    vim-<b class='flag-5'>go</b> Vim的<b class='flag-5'>Go</b>開發插件

    Go開源13周年 2022發布更多改變的Go 1.18 和 Go 1.19版本

    還有 Go 工作區、模糊測試等重要功能。 泛型是社區呼聲最大的特性,也是今年 Go 最重大的特性,它為 Go 添加了參數多態性,以允許編寫適用于
    的頭像 發表于 11-17 16:37 ?1550次閱讀

    如何讓Python和Go互相調度

    我們曾經研究過如何讓Python和Go互相調度,當時發現,將Go語言寫的模塊打包成動態鏈接庫,就能在Python中進行調度: 優劣互補! Python+
    的頭像 發表于 11-02 11:24 ?937次閱讀
    如何讓Python和<b class='flag-5'>Go</b>互相<b class='flag-5'>調度</b>
    主站蜘蛛池模板: 亲爱的妈妈6韩国电影免费观看 | 中文中幕无码亚洲视频 | 美女内射视频WWW网站午夜 | 日本三级黄色大片 | 黑人干肥婆| 久久久视频2019午夜福利 | 欧美gv明星 | 人人啪日日观看在线 | 97人摸人人澡人人人超一碰 | 美女被撕开胸罩狂揉大乳 | 国产曰批试看免费视频播放免费 | 久草国产在线播放 | 九九热伊人 | 亚洲免费观看视频 | 亚洲天堂久久久 | 熟女人妻久久精品AV天堂 | 国产精品久久久久久久久无码 | 国产99视频精品免费播放 | 亚洲 日韩 国产 中文视频 | 国产午夜精品视频在线播放 | 国内一级一级毛片a免费 | 男人J桶女人P视频无遮挡网站 | 果冻传媒2021一二三在线观看 | 亚洲理论在线a中文字幕 | 亚洲激情网站 | 美美哒免费影视8 | 丰满人妻妇伦又伦精品APP国产 | 秋霞最新高清无码鲁丝片 | 久久中文字幕亚洲精品最新 | 免费99精品国产人妻自在线 | 色老汉网址导航 | 狠狠躁天天躁小说 | 美女尿口羞羞视频 | 高h 纯肉文 | 欧美性appstin孕妇 | 办公室韩国电影免费完整版 | 蜜臀AV人妻久久无码精品麻豆 | 国产成人精品永久免费视频 | XXX欧美性兽交| 果冻传媒免费观看 | 11 13加污女qq看他下面 |

    電子發燒友

    中國電子工程師最喜歡的網站

    • 2931785位工程師會員交流學習
    • 獲取您個性化的科技前沿技術信息
    • 參加活動獲取豐厚的禮品