golang time包
和python一樣,golang時間處理還是比較方便的，以下介紹了golang 時間日期，相關包 "time"的相關內容，分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹。
時間戳
當前時間戳
|
1
2
|
fmt.Println(time.Now().Unix())# 1389058332 |
str格式化時間
當前格式化時間
|
1
2
|
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格式化時間
|
1
2
3
|
str_time := time.Unix(1389058332, 0).Format("2006-01-02 15:04:05")fmt.Println(str_time)# 2014-01-07 09:32:12 |
str格式化時間轉時間戳
這個比較麻煩
|
1
2
3
4
|
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
|
1
2
3
4
5
6
|
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定時器相關的入口主要有以下幾種方法：
|
1
2
3
4
5
6
|
<-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的源碼如下：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
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包內
|
1
2
3
4
5
6
7
8
9
10
11
12
|
func startTimer(t *timer) { if raceenabled { racerelease(unsafe.Pointer(t)) } addtimer(t)}func addtimer(t *timer) { lock(&timers.lock) addtimerLocked(t) unlock(&timers.lock)} |
上面的代碼為了看著方便，我將他們都放在一起
下面代碼都寫出部分注釋
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
|
// 使用鎖將計時器添加到堆中// 如果是第一次運行此方法則啟動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存儲定時任務結構
addtimer在堆中插入一個值，然后保持最小堆的特性，其實這個結構本質就是最小優先隊列的一個應用，然后將時間轉換一個絕對時間處理，通過睡眠和喚醒找出定時任務，這里閱讀起來源碼很容易，所以只將代碼和部分注釋寫出。
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對服務器之家的支持。
原文鏈接：https://zhuanlan.zhihu.com/p/31634188
