欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Golang中定時(shí)器的陷阱詳解

 更新時(shí)間:2018年09月09日 16:24:54   作者:shitaibin  
這篇文章主要給大家介紹了關(guān)于Golang中定時(shí)器陷阱的相關(guān)資料,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家學(xué)習(xí)或者使用golang具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

在業(yè)務(wù)中,我們經(jīng)常需要基于定時(shí)任務(wù)來觸發(fā)來實(shí)現(xiàn)各種功能。比如TTL會(huì)話管理、鎖、定時(shí)任務(wù)(鬧鐘)或更復(fù)雜的狀態(tài)切換等等。百納網(wǎng)主要給大家介紹了關(guān)于Golang定時(shí)器陷阱的相關(guān)內(nèi)容,所謂陷阱,就是它不是你認(rèn)為的那樣,這種認(rèn)知誤差可能讓你的軟件留下隱藏Bug。剛好Timer就有3個(gè)陷阱,我們會(huì)講

1)Reset的陷阱和

2)通道的陷阱,

3)Stop的陷阱與Reset的陷阱類似,自己探索吧。

下面話不多說了,來一起看看詳細(xì)的介紹吧

Reset的陷阱在哪

Timer.Reset()函數(shù)的返回值是bool類型,我們看一個(gè)問題三連:

  • 它的返回值代表什么呢?
  • 我們想要的成功是什么?
  • 失敗是什么?

成功:一段時(shí)間之后定時(shí)器超時(shí),收到超時(shí)事件。

失敗:成功的反面,我們收不到那個(gè)事件。對(duì)于失敗,我們應(yīng)當(dāng)做些什么,確保我們的定時(shí)器發(fā)揮作用。

Reset的返回值是不是這個(gè)意思?

通過查看文檔和實(shí)現(xiàn),Timer.Reset()的返回值并不符合我們的預(yù)期,這就是誤差。它的返回值不代表重設(shè)定時(shí)器成功或失敗,而是在表達(dá)定時(shí)器在重設(shè)前的狀態(tài):

  • 當(dāng)Timer已經(jīng)停止或者超時(shí),返回false。
  • 當(dāng)定時(shí)器未超時(shí)時(shí),返回true。

所以,當(dāng)Reset返回false時(shí),我們并不能認(rèn)為一段時(shí)間之后,超時(shí)不會(huì)到來,實(shí)際上可能會(huì)到來,定時(shí)器已經(jīng)生效了。

跳過陷阱,再遇陷阱

如何跳過前面的陷阱,讓Reset符合我們的預(yù)期功能呢?直接忽視Reset的返回值好了,它不能幫助你達(dá)到預(yù)期的效果。

真正的陷阱是Timer的通道,它和我們預(yù)期的成功、失敗密切相關(guān)。我們所期望的定時(shí)器設(shè)置失敗,通常只和通道有關(guān):設(shè)置定時(shí)器前,定時(shí)器的通道Timer.C中是否已經(jīng)有數(shù)據(jù)。

  • 如果有,我們?cè)O(shè)置的定時(shí)器失敗了,我們可能讀到不正確的超時(shí)事件。
  • 如果沒有,我們?cè)O(shè)置的定時(shí)器成功了,我們?cè)谠O(shè)定的時(shí)間得到超時(shí)事件。

接下來解釋為何失敗只與通道中是否存在超時(shí)事件有關(guān)。

定時(shí)器的緩存通道大小只為1,無法多存放超時(shí)事件,看源碼。

// NewTimer creates a new Timer that will send
// the current time on its channel after at least duration d.
func NewTimer(d Duration) *Timer {
 c := make(chan Time, 1) // 緩存通道大小為1
 t := &Timer{
  C: c,
  r: runtimeTimer{
   when: when(d),
   f: sendTime,
   arg: c,
  },
 }
 startTimer(&t.r)
 return t
}

定時(shí)器創(chuàng)建后是單獨(dú)運(yùn)行的,超時(shí)后會(huì)向通道寫入數(shù)據(jù),你從通道中把數(shù)據(jù)讀走。當(dāng)前一次的超時(shí)數(shù)據(jù)沒有被讀取,而設(shè)置了新的定時(shí)器,然后去通道讀數(shù)據(jù),結(jié)果讀到的是上次超時(shí)的超時(shí)事件,看似成功,實(shí)則失敗,完全掉入陷阱。

跨越陷阱,確保成功

如果確保Timer.Reset()成功,得到我們想要的結(jié)果?Timer.Reset()前清空通道。

當(dāng)業(yè)務(wù)場(chǎng)景簡單時(shí),沒有必要主動(dòng)清空通道。比如,處理流程是:設(shè)置1次定時(shí)器,處理一次定時(shí)器,中間無中斷,下次Reset前,通道必然是空的。

當(dāng)業(yè)務(wù)場(chǎng)景復(fù)雜時(shí),不確定通道是否為空,那就主動(dòng)清除。

if len(Timer.C) > 0{
 <-Timer.C
}
Timer.Reset(time.Second)

測(cè)試代碼

package main

import (
 "fmt"
 "time"
)

// 不同情況下,Timer.Reset()的返回值
func test1() {
 fmt.Println("第1個(gè)測(cè)試:Reset返回值和什么有關(guān)?")
 tm := time.NewTimer(time.Second)
 defer tm.Stop()

 quit := make(chan bool)

 // 退出事件
 go func() {
  time.Sleep(3 * time.Second)
  quit <- true
 }()

 // Timer未超時(shí),看Reset的返回值
 if !tm.Reset(time.Second) {
  fmt.Println("未超時(shí),Reset返回false")
 } else {
  fmt.Println("未超時(shí),Reset返回true")
 }

 // 停止timer
 tm.Stop()
 if !tm.Reset(time.Second) {
  fmt.Println("停止Timer,Reset返回false")
 } else {
  fmt.Println("停止Timer,Reset返回true")
 }

 // Timer超時(shí)
 for {
  select {
  case <-quit:
   return

  case <-tm.C:
   if !tm.Reset(time.Second) {
    fmt.Println("超時(shí),Reset返回false")
   } else {
    fmt.Println("超時(shí),Reset返回true")
   }
  }
 }
}

func test2() {
 fmt.Println("\n第2個(gè)測(cè)試:超時(shí)后,不讀通道中的事件,可以Reset成功嗎?")
 sm2Start := time.Now()
 tm2 := time.NewTimer(time.Second)
 time.Sleep(2 * time.Second)
 fmt.Printf("Reset前通道中事件的數(shù)量:%d\n", len(tm2.C))
 if !tm2.Reset(time.Second) {
  fmt.Println("不讀通道數(shù)據(jù),Reset返回false")
 } else {
  fmt.Println("不讀通道數(shù)據(jù),Reset返回true")
 }
 fmt.Printf("Reset后通道中事件的數(shù)量:%d\n", len(tm2.C))

 select {
 case t := <-tm2.C:
  fmt.Printf("tm2開始的時(shí)間: %v\n", sm2Start.Unix())
  fmt.Printf("通道中事件的時(shí)間:%v\n", t.Unix())
  if t.Sub(sm2Start) <= time.Second+time.Millisecond {
   fmt.Println("通道中的時(shí)間是重新設(shè)置sm2前的時(shí)間,即第一次超時(shí)的時(shí)間,所以第二次Reset失敗了")
  }
 }

 fmt.Printf("讀通道后,其中事件的數(shù)量:%d\n", len(tm2.C))
 tm2.Reset(time.Second)
 fmt.Printf("再次Reset后,通道中事件的數(shù)量:%d\n", len(tm2.C))
 time.Sleep(2 * time.Second)
 fmt.Printf("超時(shí)后通道中事件的數(shù)量:%d\n", len(tm2.C))
}

func test3() {
 fmt.Println("\n第3個(gè)測(cè)試:Reset前清空通道,盡可能通暢")
 smStart := time.Now()
 tm := time.NewTimer(time.Second)
 time.Sleep(2 * time.Second)
 if len(tm.C) > 0 {
  <-tm.C
 }
 tm.Reset(time.Second)

 // 超時(shí)
 t := <-tm.C
 fmt.Printf("tm開始的時(shí)間: %v\n", smStart.Unix())
 fmt.Printf("通道中事件的時(shí)間:%v\n", t.Unix())
 if t.Sub(smStart) <= time.Second+time.Millisecond {
  fmt.Println("通道中的時(shí)間是重新設(shè)置sm前的時(shí)間,即第一次超時(shí)的時(shí)間,所以第二次Reset失敗了")
 } else {
  fmt.Println("通道中的時(shí)間是重新設(shè)置sm后的時(shí)間,Reset成功了")
 }
}

func main() {
 test1()
 test2()
 test3()
}

總結(jié)

以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問大家可以留言交流,謝謝大家對(duì)腳本之家的支持。

相關(guān)文章

  • 數(shù)據(jù)競(jìng)爭和內(nèi)存重分配Golang slice并發(fā)不安全問題解決

    數(shù)據(jù)競(jìng)爭和內(nèi)存重分配Golang slice并發(fā)不安全問題解決

    這篇文章主要為大家介紹了數(shù)據(jù)競(jìng)爭和內(nèi)存重分配Golang slice并發(fā)不安全問題解決,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-10-10
  • Go語言實(shí)現(xiàn)配置熱加載的方法分享

    Go語言實(shí)現(xiàn)配置熱加載的方法分享

    web項(xiàng)目,經(jīng)常需要熱啟動(dòng)各種各樣的配置信息,一旦這些服務(wù)發(fā)生變更,我們需要重新啟動(dòng)web server,以使配置生效,實(shí)現(xiàn)配置熱加載,本文為大家整理了幾個(gè)方法實(shí)現(xiàn)這個(gè)需求,需要的可以參考下
    2023-05-05
  • 在go中使用omitempty的代碼實(shí)例

    在go中使用omitempty的代碼實(shí)例

    今天小編就為大家分享一篇關(guān)于在go中使用omitempty的代碼實(shí)例,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧
    2019-04-04
  • 關(guān)于Go語言中的IO操作詳解

    關(guān)于Go語言中的IO操作詳解

    在現(xiàn)代軟件開發(fā)中,高效的輸入輸出(I/O)操作是提高程序性能的關(guān)鍵之一,Go語言提供了豐富的I/O操作接口,使得文件讀寫、網(wǎng)絡(luò)通信等任務(wù)變得簡單而高效,本文介紹了關(guān)于Go語言中的IO操作,需要的朋友可以參考下
    2024-10-10
  • go zero微服務(wù)框架logx日志組件剖析

    go zero微服務(wù)框架logx日志組件剖析

    這篇文章主要為大家介紹了go zero微服務(wù)框架logx日志組件剖析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-09-09
  • 文字解說Golang Goroutine和線程的區(qū)別

    文字解說Golang Goroutine和線程的區(qū)別

    goroutine 是 Go語言中的輕量級(jí)線程實(shí)現(xiàn),由 Go 運(yùn)行時(shí)(runtime)管理,使用每一個(gè) go 關(guān)鍵字將會(huì)額外開啟一個(gè)新的協(xié)程 goroutine,今天通過本文給大家介紹下Golang Goroutine和線程的區(qū)別,感興趣的朋友一起看看吧
    2022-03-03
  • GoLang?channel關(guān)閉狀態(tài)相關(guān)操作詳解

    GoLang?channel關(guān)閉狀態(tài)相關(guān)操作詳解

    Channel?和?goroutine?的結(jié)合是?Go?并發(fā)編程的大殺器。而?Channel?的實(shí)際應(yīng)用也經(jīng)常讓人眼前一亮,通過與?select,cancel,timer?等結(jié)合,它能實(shí)現(xiàn)各種各樣的功能。接下來,我們就要介紹GoLang?channel關(guān)閉狀態(tài)相關(guān)操作
    2022-10-10
  • golang中使用sync.Map的方法

    golang中使用sync.Map的方法

    這篇文章主要介紹了golang中使用sync.Map的方法,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2020-06-06
  • Golang 實(shí)現(xiàn)插入排序的方法示例(2種)

    Golang 實(shí)現(xiàn)插入排序的方法示例(2種)

    這篇文章主要介紹了Golang 實(shí)現(xiàn)插入排序的方法示例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-02-02
  • Go語言中三個(gè)輸入函數(shù)(scanf,scan,scanln)的區(qū)別解析

    Go語言中三個(gè)輸入函數(shù)(scanf,scan,scanln)的區(qū)別解析

    本文詳細(xì)介紹了Go語言中三個(gè)輸入函數(shù)Scanf、Scan和Scanln的區(qū)別,包括用法、功能和輸入終止條件等,本文給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧
    2024-10-10

最新評(píng)論