最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

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

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

前言

在業(yè)務(wù)中,我們經(jīng)常需要基于定時(shí)任務(wù)來(lái)觸發(fā)來(lái)實(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的陷阱類似,自己探索吧。

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

Reset的陷阱在哪

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

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

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

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

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

通過(guò)查看文檔和實(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ì)到來(lái),實(shí)際上可能會(huì)到來(lái),定時(shí)器已經(jīng)生效了。

跳過(guò)陷阱,再遇陷阱

如何跳過(guò)前面的陷阱,讓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í)事件。
  • 如果沒(méi)有,我們?cè)O(shè)置的定時(shí)器成功了,我們?cè)谠O(shè)定的時(shí)間得到超時(shí)事件。

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

定時(shí)器的緩存通道大小只為1,無(wú)法多存放超時(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ì)向通道寫(xiě)入數(shù)據(jù),你從通道中把數(shù)據(jù)讀走。當(dāng)前一次的超時(shí)數(shù)據(jù)沒(méi)有被讀取,而設(shè)置了新的定時(shí)器,然后去通道讀數(shù)據(jù),結(jié)果讀到的是上次超時(shí)的超時(shí)事件,看似成功,實(shí)則失敗,完全掉入陷阱。

跨越陷阱,確保成功

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

當(dāng)業(yè)務(wù)場(chǎng)景簡(jiǎn)單時(shí),沒(méi)有必要主動(dòng)清空通道。比如,處理流程是:設(shè)置1次定時(shí)器,處理一次定時(shí)器,中間無(wú)中斷,下次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開(kāi)始的時(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開(kāi)始的時(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é)

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

相關(guān)文章

  • Golang?sync.Map底層實(shí)現(xiàn)場(chǎng)景示例詳解

    Golang?sync.Map底層實(shí)現(xiàn)場(chǎng)景示例詳解

    這篇文章主要為大家介紹了Golang?sync.Map底層實(shí)現(xiàn)及使用場(chǎng)景示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2023-09-09
  • Golang?template?包基本原理分析

    Golang?template?包基本原理分析

    這篇文章主要為大家介紹了Golang?template?包基本原理分析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪
    2022-09-09
  • Go標(biāo)準(zhǔn)庫(kù)encoding/gob的具體使用

    Go標(biāo)準(zhǔn)庫(kù)encoding/gob的具體使用

    Go標(biāo)準(zhǔn)庫(kù)encoding/gob實(shí)現(xiàn)二進(jìn)制序列化與反序列化,本文主要介紹了Go標(biāo)準(zhǔn)庫(kù)encoding/gob的具體使用,感興趣的可以了解一下
    2025-06-06
  • 淺談golang類型斷言,失敗類型斷言返回值問(wèn)題

    淺談golang類型斷言,失敗類型斷言返回值問(wèn)題

    這篇文章主要介紹了淺談golang類型斷言,失敗類型斷言返回值問(wèn)題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧
    2020-12-12
  • 詳解Golang中Channel的原理和使用技巧

    詳解Golang中Channel的原理和使用技巧

    Channel管道提供了一種機(jī)制,它在兩個(gè)并發(fā)執(zhí)行的協(xié)程之間進(jìn)行同步,并通過(guò)傳遞與該管道元素類型相符的值來(lái)進(jìn)行通信。本文主要介紹了Channel的原理和使用技巧,需要的可以參考一下
    2022-11-11
  • Go 泛型和非泛型代碼詳解

    Go 泛型和非泛型代碼詳解

    Go 在 1.17 中支持泛型,但是默認(rèn)未開(kāi)啟;1.18 中會(huì)正式支持泛型,下面文章內(nèi)容小編將給大家講解Go 語(yǔ)言中的泛型和非泛型并且附上代碼詳解,剛興趣的小伙伴請(qǐng)參考下面文章的具體內(nèi)容
    2021-10-10
  • Go語(yǔ)言實(shí)現(xiàn)冒泡排序、選擇排序、快速排序及插入排序的方法

    Go語(yǔ)言實(shí)現(xiàn)冒泡排序、選擇排序、快速排序及插入排序的方法

    這篇文章主要介紹了Go語(yǔ)言實(shí)現(xiàn)冒泡排序、選擇排序、快速排序及插入排序的方法,以實(shí)例形式詳細(xì)分析了幾種常見(jiàn)的排序技巧與實(shí)現(xiàn)方法,非常具有實(shí)用價(jià)值,需要的朋友可以參考下
    2015-02-02
  • 深入理解Golang?make和new的區(qū)別及實(shí)現(xiàn)原理

    深入理解Golang?make和new的區(qū)別及實(shí)現(xiàn)原理

    在Go語(yǔ)言中,有兩個(gè)比較雷同的內(nèi)置函數(shù),分別是new和make方法,二者都可以用來(lái)分配內(nèi)存,那他們有什么區(qū)別呢?下面我們就從底層來(lái)分析一下二者的不同。感興趣的小伙伴們可以參考借鑒,希望對(duì)大家能有所幫助
    2022-10-10
  • Go語(yǔ)言流程控制語(yǔ)句

    Go語(yǔ)言流程控制語(yǔ)句

    這篇文章介紹了Go語(yǔ)言流程控制語(yǔ)句的用法,文中通過(guò)示例代碼介紹的非常詳細(xì)。對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下
    2022-07-07
  • Go語(yǔ)言微服務(wù)中實(shí)現(xiàn)鏈路追蹤

    Go語(yǔ)言微服務(wù)中實(shí)現(xiàn)鏈路追蹤

    在微服務(wù)架構(gòu)中,鏈路追蹤技術(shù)可以幫助我們跟蹤請(qǐng)求在各個(gè)服務(wù)之間的傳播路徑,本文就來(lái)介紹一下Go語(yǔ)言微服務(wù)中實(shí)現(xiàn)鏈路追蹤,感興趣的可以了解一下
    2024-12-12

最新評(píng)論

浦江县| 鄂伦春自治旗| 博罗县| 景德镇市| 威远县| 镇雄县| 广州市| 嘉义县| 杭州市| 太谷县| 诸暨市| 新田县| 瑞昌市| 晋城| 汉川市| 如东县| 广宗县| 涞源县| 和平区| 社旗县| 绥阳县| 周至县| 兴隆县| 建瓯市| 丰原市| 台州市| 响水县| 德惠市| 方山县| 翼城县| 永德县| 神木县| 靖安县| 沙雅县| 婺源县| 阿鲁科尔沁旗| 达尔| 潢川县| 手机| 蒙阴县| 台中市|