校园春色亚洲色图_亚洲视频分类_中文字幕精品一区二区精品_麻豆一区区三区四区产品精品蜜桃

主頁 > 知識庫 > golang time包下定時器的實現方法

golang time包下定時器的實現方法

熱門標簽:鄭州亮點科技用的什么外呼系統 建造者2地圖標注 阿里云ai電話機器人 黃岡人工智能電銷機器人哪個好 釘釘有地圖標注功能嗎 惠州電銷防封電話卡 汕頭小型外呼系統 浙江高頻外呼系統多少錢一個月 濱州自動電銷機器人排名

golang time包

和python一樣,golang時間處理還是比較方便的,以下介紹了golang 時間日期,相關包 "time"的相關內容,分享出來供大家參考學習,下面話不多說了,來一起看看詳細的介紹。

時間戳

當前時間戳

fmt.Println(time.Now().Unix())
# 1389058332

str格式化時間

當前格式化時間

fmt.Println(time.Now().Format("2006-01-02 15:04:05")) // 這是個奇葩,必須是這個時間點, 據說是go誕生之日, 記憶方法:6-1-2-3-4-5
# 2014-01-07 09:42:20

時間戳轉str格式化時間

str_time := time.Unix(1389058332, 0).Format("2006-01-02 15:04:05")
fmt.Println(str_time)
# 2014-01-07 09:32:12

str格式化時間轉時間戳

這個比較麻煩

the_time := time.Date(2014, 1, 7, 5, 50, 4, 0, time.Local)
unix_time := the_time.Unix()
fmt.Println(unix_time)
# 389045004

還有一種方法,使用time.Parse

the_time, err := time.Parse("2006-01-02 15:04:05", "2014-01-08 09:04:41")
if err == nil {
unix_time := the_time.Unix()
fmt.Println(unix_time) 
}
# 1389171881

以上簡單介紹了golang中time包的相關內容,下面開始本文的正文。

引言

這篇文章簡單的介紹下golang time 包下定時器的實現,說道定時器,在我們開發過程中很常用,由于使用的場景不同,所以對定時器實際的實現也就不同,go的定時器并沒有使用SIGALARM信號實現,而是采取最小堆的方式實現(源碼包中使用數組實現的四叉樹),使用這種方式定時精度很高,但是有的時候可能我們不需要這么高精度的實現,為了更高效的利用資源,有的時候也會實現一個精度比較低的算法。

跟golang定時器相關的入口主要有以下幾種方法:

-time.Tick(time.Second)
-time.After(time.Second)
-time.NewTicker(time.Second).C
-time.NewTimer(time.Second).C
time.AfterFunc(time.Second, func() { /*do*/ })
time.Sleep(time.Second)

這里我們以其中NewTicker為入口,NewTicker的源碼如下:

func NewTicker(d Duration) *Ticker {
 if d = 0 {
 panic(errors.New("non-positive interval for NewTicker"))
 }
 c := make(chan Time, 1)
 t := Ticker{
 C: c,
 r: runtimeTimer{
 // when(d)返回一個runtimeNano() + int64(d)的未來時(到期時間)
 //runtimeNano運行時當前納秒時間
 when: when(d),
 period: int64(d), // 被喚醒的時間
 f:  sendTime, // 時間到期后的回調函數
 arg: c,  // 時間到期后的斷言參數
 },
 }
 // 將新的定時任務添加到時間堆中
 // 編譯器會將這個函數翻譯為runtime.startTimer(t *runtime.timer)
 // time.runtimeTimer翻譯為runtime.timer
 startTimer(t.r)
 return t

這里有個比較重要的是startTimer(t.r)它的實現被翻譯在runtime包內

func startTimer(t *timer) {
 if raceenabled {
 racerelease(unsafe.Pointer(t))
 }
 addtimer(t)
}

func addtimer(t *timer) {
 lock(timers.lock)
 addtimerLocked(t)
 unlock(timers.lock)
}

上面的代碼為了看著方便,我將他們都放在一起

下面代碼都寫出部分注釋

// 使用鎖將計時器添加到堆中
// 如果是第一次運行此方法則啟動timerproc
func addtimerLocked(t *timer) {
 if t.when  0 {
 t.when = 163 - 1
 }
 // t.i i是定時任務數組中的索引
 // 將新的定時任務追加到定時任務數組隊尾
 t.i = len(timers.t)
 timers.t = append(timers.t, t)
 // 使用數組實現的四叉樹最小堆根據when(到期時間)進行排序
 siftupTimer(t.i)
 // 如果t.i 索引為0
 if t.i == 0 {
 if timers.sleeping {
 // 如果還在sleep就喚醒
 timers.sleeping = false
 // 這里基于OS的同步,并進行OS系統調用
 // 在timerproc()使goroutine從睡眠狀態恢復
 notewakeup(timers.waitnote)
 }
 if timers.rescheduling {
 timers.rescheduling = false
 // 如果沒有定時器,timerproc()與goparkunlock共同sleep
 // goready這里特殊說明下,在線程創建的堆棧,它比goroutine堆棧大。
 // 函數不能增長堆棧,同時不能被調度器搶占
 goready(timers.gp, 0)
 }
 }
 if !timers.created {
 timers.created = true
 go timerproc() //這里只有初始化一次
 }
}

// Timerproc運行時間驅動的事件。
// 它sleep到計時器堆中的下一個。
// 如果addtimer插入一個新的事件,它會提前喚醒timerproc。
func timerproc() {
 timers.gp = getg()
 for {
 lock(timers.lock)
 timers.sleeping = false
 now := nanotime()
 delta := int64(-1)
 for {
 if len(timers.t) == 0 {
 delta = -1
 break
 }
 t := timers.t[0]
 delta = t.when - now
 if delta > 0 {
 break // 時間未到
 }
 if t.period > 0 {
 // 計算下一次時間
        // period被喚醒的間隔
 t.when += t.period * (1 + -delta/t.period)
 siftdownTimer(0)
 } else {
 // remove from heap
 last := len(timers.t) - 1
 if last > 0 {
  timers.t[0] = timers.t[last]
  timers.t[0].i = 0
 }
 timers.t[last] = nil
 timers.t = timers.t[:last]
 if last > 0 {
  siftdownTimer(0)
 }
 t.i = -1 // 標記移除
 }
 f := t.f
 arg := t.arg
 seq := t.seq
 unlock(timers.lock)
 if raceenabled {
 raceacquire(unsafe.Pointer(t))
 }
 f(arg, seq)
 lock(timers.lock)
 }
 if delta  0 || faketime > 0 {
 // 沒有定時器,把goroutine sleep。
 timers.rescheduling = true
 // 將當前的goroutine放入等待狀態并解鎖鎖。
 // goroutine也可以通過呼叫goready(gp)來重新運行。
 goparkunlock(timers.lock, "timer goroutine (idle)", traceEvGoBlock, 1)
 continue
 }
 // At least one timer pending. Sleep until then.
 timers.sleeping = true
 timers.sleepUntil = now + delta
 // 重置
 noteclear(timers.waitnote)
 unlock(timers.lock)
 // 使goroutine進入睡眠狀態,直到notewakeup被調用,
 // 通過notewakeup 喚醒
 notetsleepg(timers.waitnote, delta)
 }
}

golang使用最小堆(最小堆是滿足除了根節點以外的每個節點都不小于其父節點的堆)實現的定時器。golang []*timer結構如下:


golang存儲定時任務結構

addtimer在堆中插入一個值,然后保持最小堆的特性,其實這個結構本質就是最小優先隊列的一個應用,然后將時間轉換一個絕對時間處理,通過睡眠和喚醒找出定時任務,這里閱讀起來源碼很容易,所以只將代碼和部分注釋寫出。

總結

以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作具有一定的參考學習價值,如果有疑問大家可以留言交流,謝謝大家對腳本之家的支持。

您可能感興趣的文章:
  • Golang定時器的2種實現方法與區別
  • golang定時器和超時的使用詳解
  • Golang 定時器(Timer 和 Ticker),這篇文章就夠了
  • Golang中定時器的陷阱詳解
  • 用golang實現一個定時器任務隊列實例
  • golang中定時器cpu使用率高的現象詳析
  • Golang 定時器的終止與重置實現

標簽:瀘州 泰安 晉中 滄州 阿壩 駐馬店 昭通 東營

巨人網絡通訊聲明:本文標題《golang time包下定時器的實現方法》,本文關鍵詞  golang,time,包下,定時器,的,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《golang time包下定時器的實現方法》相關的同類信息!
  • 本頁收集關于golang time包下定時器的實現方法的相關信息資訊供網民參考!
  • 推薦文章
    校园春色亚洲色图_亚洲视频分类_中文字幕精品一区二区精品_麻豆一区区三区四区产品精品蜜桃
    麻豆高清免费国产一区| 国产精品 欧美精品| 国产一区二区剧情av在线| 欧美一区在线视频| 国产精品中文字幕一区二区三区| 日韩午夜激情电影| 国产在线不卡视频| 国产精品亲子乱子伦xxxx裸| 成人综合日日夜夜| 亚洲资源在线观看| 久久网站热最新地址| 91免费看视频| 日韩电影在线一区二区三区| 国产午夜精品一区二区三区嫩草 | 国内精品第一页| 自拍偷拍亚洲欧美日韩| 日韩一区二区在线看| 不卡的av网站| 麻豆中文一区二区| 亚洲国产中文字幕| 国产视频视频一区| 91精品啪在线观看国产60岁| 成人中文字幕合集| 琪琪一区二区三区| 亚洲乱码国产乱码精品精的特点 | 国产喷白浆一区二区三区| 欧美在线观看一区二区| 国产高清亚洲一区| 欧美aaaaa成人免费观看视频| 国产精品久久久久三级| 亚洲精品一区二区三区99| 欧美视频在线观看一区二区| 不卡av在线免费观看| 国产综合久久久久影院| 日本人妖一区二区| 午夜日韩在线观看| 亚洲风情在线资源站| 国产精品久久三| 国产婷婷精品av在线| 精品日韩一区二区三区| 51午夜精品国产| 欧美日韩五月天| 91高清视频在线| 99视频在线精品| www.99精品| 97精品视频在线观看自产线路二| 国产风韵犹存在线视精品| 国产麻豆9l精品三级站| 国产一区福利在线| 久久国产麻豆精品| 精品一区二区三区av| 激情综合网最新| 国产一区二区免费看| 丁香五精品蜜臀久久久久99网站| 国产iv一区二区三区| 成人一区二区三区在线观看| 成人免费视频视频| 成人aa视频在线观看| 91网站在线播放| 在线观看精品一区| 欧美精品电影在线播放| 欧美一区二区三区免费视频| 日韩一区二区视频| 久久一区二区三区国产精品| 国产欧美日韩激情| 亚洲少妇屁股交4| 亚洲图片有声小说| 麻豆成人免费电影| 国产成人欧美日韩在线电影| 97se狠狠狠综合亚洲狠狠| 91久久国产最好的精华液| 欧美日韩第一区日日骚| 2017欧美狠狠色| 综合自拍亚洲综合图不卡区| 亚洲综合丁香婷婷六月香| 日本在线播放一区二区三区| 国产高清不卡一区二区| 色婷婷国产精品久久包臀| 欧美精品精品一区| 日本一区二区动态图| 亚洲福利一二三区| 国产91精品欧美| 精品视频在线免费| 久久九九国产精品| 一区二区三区 在线观看视频| 日韩精品乱码免费| 成熟亚洲日本毛茸茸凸凹| 欧美日本一区二区三区四区| 国产欧美一区二区精品性| 性做久久久久久免费观看| 国产福利一区二区三区在线视频| 精品视频一区三区九区| 欧美国产1区2区| 蜜臀99久久精品久久久久久软件| 国产精品一二三四五| 欧美日韩美少妇| 国产精品区一区二区三区| 麻豆精品国产传媒mv男同| 91小视频免费观看| 久久久久久久久伊人| 性欧美大战久久久久久久久| 成人精品高清在线| 日韩精品一区在线观看| 一区二区高清在线| 不卡的av电影| 欧美精品一区二区三| 亚洲成av人片一区二区梦乃| 99精品桃花视频在线观看| 精品99999| 秋霞电影网一区二区| 欧美最新大片在线看| 在线播放亚洲一区| 亚洲高清久久久| 91猫先生在线| 亚洲三级免费观看| caoporen国产精品视频| 国产欧美一区二区精品忘忧草| 久久精品国产99久久6| 欧美男生操女生| 亚洲成a人片综合在线| 色婷婷激情一区二区三区| 亚洲少妇30p| 99久久久国产精品| 亚洲欧洲日韩av| gogo大胆日本视频一区| 中文字幕第一页久久| 丁香婷婷综合激情五月色| 国产亚洲一二三区| 丰满岳乱妇一区二区三区| 国产亚洲欧美日韩俺去了| 国产一区二区美女诱惑| 久久久久久久久久电影| 国产成人亚洲综合a∨婷婷图片| 久久精品欧美日韩| gogogo免费视频观看亚洲一| 亚洲蜜臀av乱码久久精品蜜桃| 91丝袜呻吟高潮美腿白嫩在线观看| 中文字幕字幕中文在线中不卡视频| eeuss鲁片一区二区三区在线看| 国产精品不卡在线| 欧美伊人精品成人久久综合97 | 91小视频在线| 亚洲精品欧美二区三区中文字幕| 91小视频免费看| 亚洲成人中文在线| 日韩一级精品视频在线观看| 精品一区二区三区av| 《视频一区视频二区| 欧美日韩综合在线免费观看| 天天色综合成人网| 久久久精品国产免大香伊| www.日韩在线| 日韩精品视频网| 亚洲国产精品高清| 欧美日韩亚洲高清一区二区| 韩国精品主播一区二区在线观看| 中文字幕第一区综合| 欧美日高清视频| 国产成人精品三级麻豆| 一区二区三区四区中文字幕| 91精品国产综合久久久久久久| 国产大陆亚洲精品国产| 亚洲一区欧美一区| 国产性色一区二区| 欧美久久久一区| 成人h动漫精品一区二区| 亚洲一二三四区不卡| 国产亚洲制服色| 91精品啪在线观看国产60岁| 99久久综合99久久综合网站| 久久精品国产在热久久| 亚洲免费成人av| 久久久精品影视| 555夜色666亚洲国产免| 91视频你懂的| 国产精品一区一区| 蜜桃精品在线观看| 夜夜精品视频一区二区| 中文字幕欧美区| 日韩免费观看高清完整版在线观看| 不卡av在线免费观看| 精品一区二区在线看| 亚洲成人福利片| 亚洲女女做受ⅹxx高潮| 久久久久久久久久久黄色| 欧美一区二区在线看| 在线精品视频免费播放| a级精品国产片在线观看| 国产一区不卡在线| 日韩精品1区2区3区| 亚洲福利电影网| 亚洲一二三专区| 亚洲精品伦理在线| 国产精品理伦片| 中文字幕av一区二区三区高 | 国产精品毛片a∨一区二区三区| 精品奇米国产一区二区三区| 制服丝袜一区二区三区| 欧美视频精品在线| 色综合中文字幕国产|