欧美一区二区三区老妇人-欧美做爰猛烈大尺度电-99久久夜色精品国产亚洲a-亚洲福利视频一区二区

golangtime包下定時器的實(shí)現(xiàn)方法

golang time包

創(chuàng)新互聯(lián)公司是一家專業(yè)提供武都企業(yè)網(wǎng)站建設(shè),專注與成都網(wǎng)站設(shè)計、成都網(wǎng)站制作、H5頁面制作、小程序制作等業(yè)務(wù)。10年已為武都眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)站制作公司優(yōu)惠進(jìn)行中。

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

時間戳

當(dāng)前時間戳

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

str格式化時間

當(dāng)前格式化時間

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

時間戳轉(zhuǎn)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格式化時間轉(zhuǎn)時間戳

這個比較麻煩

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包的相關(guān)內(nèi)容，下面開始本文的正文。

引言

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

跟golang定時器相關(guān)的入口主要有以下幾種方法：

<-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運(yùn)行時當(dāng)前納秒時間
 when: when(d),
 period: int64(d), // 被喚醒的時間
 f:  sendTime, // 時間到期后的回調(diào)函數(shù)
 arg: c,  // 時間到期后的斷言參數(shù)
 },
 }
 // 將新的定時任務(wù)添加到時間堆中
 // 編譯器會將這個函數(shù)翻譯為runtime.startTimer(t *runtime.timer)
 // time.runtimeTimer翻譯為runtime.timer
 startTimer(&t.r)
 return t

這里有個比較重要的是startTimer(&t.r)它的實(shí)現(xiàn)被翻譯在runtime包內(nèi)

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

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

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

下面代碼都寫出部分注釋

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

// Timerproc運(yùn)行時間驅(qū)動的事件。
// 它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 // 標(biāo)記移除
 }
 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
 // 將當(dāng)前的goroutine放入等待狀態(tài)并解鎖鎖。
 // goroutine也可以通過呼叫g(shù)oready(gp)來重新運(yùn)行。
 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進(jìn)入睡眠狀態(tài)，直到notewakeup被調(diào)用，
 // 通過notewakeup 喚醒
 notetsleepg(&timers.waitnote, delta)
 }
}

golang使用最小堆(最小堆是滿足除了根節(jié)點(diǎn)以外的每個節(jié)點(diǎn)都不小于其父節(jié)點(diǎn)的堆)實(shí)現(xiàn)的定時器。golang []*timer結(jié)構(gòu)如下:

golang time包下定時器的實(shí)現(xiàn)方法
golang存儲定時任務(wù)結(jié)構(gòu)

addtimer在堆中插入一個值，然后保持最小堆的特性，其實(shí)這個結(jié)構(gòu)本質(zhì)就是最小優(yōu)先隊(duì)列的一個應(yīng)用，然后將時間轉(zhuǎn)換一個絕對時間處理，通過睡眠和喚醒找出定時任務(wù)，這里閱讀起來源碼很容易，所以只將代碼和部分注釋寫出。

總結(jié)

以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對創(chuàng)新互聯(lián)的支持。

網(wǎng)頁題目：golangtime包下定時器的實(shí)現(xiàn)方法
標(biāo)題鏈接：http://chinadenli.net/article4/geosoe.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供關(guān)鍵詞優(yōu)化、域名注冊、網(wǎng)站維護(hù)、網(wǎng)站排名、外貿(mào)網(wǎng)站建設(shè)、App開發(fā)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)

成都app開發(fā)公司