亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb

首頁 > 編程 > Golang > 正文

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

2020-04-01 19:00:58
字體:
來源:轉載
供稿:網友

golang/254221.html">golang/196404.html">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).Ctime.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)}

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

下面代碼都寫出部分注釋

// 使用鎖將計時器添加到堆中// 如果是第一次運行此方法則啟動timerprocfunc addtimerLocked(t *timer) { if t.when < 0 { t.when = 1<<63 - 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,time,定時器,定時器使用,time包
golang存儲定時任務結構

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

總結

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


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
亚洲香蕉成人av网站在线观看_欧美精品成人91久久久久久久_久久久久久久久久久亚洲_热久久视久久精品18亚洲精品_国产精自产拍久久久久久_亚洲色图国产精品_91精品国产网站_中文字幕欧美日韩精品_国产精品久久久久久亚洲调教_国产精品久久一区_性夜试看影院91社区_97在线观看视频国产_68精品久久久久久欧美_欧美精品在线观看_国产精品一区二区久久精品_欧美老女人bb
欧美日韩国产综合新一区| 57pao国产精品一区| 亚洲一区二区久久久久久| 久久久久久久久电影| 日韩欧美亚洲范冰冰与中字| 国产精品国产三级国产aⅴ9色| 亚洲石原莉奈一区二区在线观看| 国产亚洲综合久久| 91久热免费在线视频| 久久久久九九九九| 亚洲电影在线观看| 国产精品免费一区豆花| 久久精品国产成人| 亚洲性无码av在线| 亚洲一区第一页| 亚洲国内精品视频| 最新亚洲国产精品| 亚洲欧洲中文天堂| 亚洲综合中文字幕在线| 日本伊人精品一区二区三区介绍| 日韩成人中文电影| 欧美黄网免费在线观看| 亚洲激情在线视频| 自拍偷拍亚洲精品| 久久影院资源站| 国产suv精品一区二区| 欧洲亚洲免费视频| 国产福利成人在线| 国产一区二区久久精品| 久久人人爽亚洲精品天堂| 国产精品久久久久久久久| 欧美在线欧美在线| 欧美高跟鞋交xxxxhd| 国产精品成人播放| 日韩女优人人人人射在线视频| 亚洲高清在线观看| 国产成人综合亚洲| 国产色综合天天综合网| 91久久在线视频| 亚洲欧美日韩中文在线| 欧美一区二区三区艳史| 欧美电影免费观看网站| 91久久在线视频| 久久九九免费视频| 亚洲免费av电影| 91欧美视频网站| 国产一区二区三区视频| 欧美最顶级丰满的aⅴ艳星| 亚洲黄色有码视频| 亚洲成色777777在线观看影院| 欧美激情xxxx性bbbb| 久久伊人色综合| 91精品国产沙发| 欧美成aaa人片在线观看蜜臀| 国产精品18久久久久久麻辣| 国产精品成人av在线| 日韩视频第一页| 色爱精品视频一区| 欧美裸体xxxx极品少妇| 欧美专区日韩视频| 亚洲国产精品电影| 亚洲黄色www网站| 永久免费看mv网站入口亚洲| 欧美日韩国产999| 国产日韩欧美视频在线| 欧美激情精品久久久久久变态| 国产精品一区二区久久| 欧美在线视频网站| 日韩欧美亚洲一二三区| 亚洲电影免费观看高清| 日本a级片电影一区二区| 欧美黄色性视频| 国产欧美日韩丝袜精品一区| 国产精品久久久久免费a∨| 亚洲伊人久久综合| 色樱桃影院亚洲精品影院| 亚洲天堂网在线观看| 亚洲欧美激情四射在线日| 亚洲成色777777女色窝| 伦理中文字幕亚洲| 亚洲综合一区二区不卡| 亚洲精品国产成人| 亚洲精品视频网上网址在线观看| 成人欧美一区二区三区黑人孕妇| 欧美一级片久久久久久久| 国产精品日韩在线播放| 激情懂色av一区av二区av| 最近2019年中文视频免费在线观看| 深夜福利亚洲导航| 国产成人精品免费视频| 亚洲人高潮女人毛茸茸| 91av网站在线播放| 色综合91久久精品中文字幕| 精品久久久久久久久久ntr影视| 一区二区三区黄色| 欧美在线国产精品| 91大神在线播放精品| 国产精品1区2区在线观看| 免费不卡欧美自拍视频| 人人爽久久涩噜噜噜网站| 尤物99国产成人精品视频| 欧美成人精品在线视频| 亚洲美女免费精品视频在线观看| 欧美区二区三区| 国产成人a亚洲精品| 成人午夜激情网| 国产91色在线|| 亚洲成人免费在线视频| 国产精品久久久久久久久久东京| 欧美激情中文字幕乱码免费| 欧日韩在线观看| 亚洲欧美日韩中文在线| 精品欧美aⅴ在线网站| 日韩欧美精品网站| 精品国产91久久久久久老师| 亚洲国产中文字幕在线观看| 成人国产精品久久久| 成人激情在线播放| 正在播放国产一区| 久久久综合av| 欧美尤物巨大精品爽| 欧美电影在线观看完整版| 色无极亚洲影院| 疯狂做受xxxx高潮欧美日本| 欧美成aaa人片免费看| 亚洲2020天天堂在线观看| 91精品91久久久久久| 日本精品一区二区三区在线播放视频| 亚洲欧美另类中文字幕| 美女国内精品自产拍在线播放| 亚洲美女性视频| 国产精品999| 91九色单男在线观看| 久久久久久亚洲精品不卡| 日韩av观看网址| 国产精品日韩av| 欧美大片在线看| 奇米一区二区三区四区久久| 不卡在线观看电视剧完整版| 九九热在线精品视频| 日韩免费电影在线观看| 2019中文字幕在线免费观看| 国产精品综合不卡av| 国产精品99久久久久久久久久久久| 欧美福利视频网站| 国产噜噜噜噜噜久久久久久久久| 日韩欧美精品网址| 91精品国产91久久| 中文字幕日韩av综合精品| 亚洲理论电影网| 国产亚洲人成a一在线v站| 久久精品国产久精国产思思| 日韩在线视频观看正片免费网站| 久久伊人91精品综合网站| 国语对白做受69| 性夜试看影院91社区| 少妇高潮 亚洲精品| 成人免费直播live| 久久亚洲精品一区| 欧美福利视频网站| 视频直播国产精品| 国产精品成人国产乱一区| 国产mv免费观看入口亚洲| 日韩av电影免费观看高清|