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

Go進階之定時器Ticker的實現(xiàn)示例

 更新時間:2026年02月10日 10:41:23   作者:H_拾憶  
本文主要介紹了Go進階之定時器Ticker的實現(xiàn)示例,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

Ticker是周期性定時器.即周期性的觸發(fā)一個事件.通過Ticker本身提供的管道將事件

傳遞出去.

Ticker數(shù)據(jù)結(jié)構(gòu):

源碼位置:src/time/tick.go

type Ticker struct {
    C          <-chan Time // The channel on which the ticks are delivered.
    initTicker bool
}

Ticker對外僅暴露了一個channel.當(dāng)指定時間到來時就往該channel中寫入系統(tǒng)時

間.即一個事件.

1.簡單定時任務(wù):

func main() {
    ticker := time.NewTicker(1 * time.Second)

    defer ticker.Stop()

    for range ticker.C {
       log.Println("tick")
    }
}

執(zhí)行結(jié)果:

定時聚合任務(wù):

示例:

func TickerLaunch() {
    //5分鐘執(zhí)行一次.
    ticker := time.NewTicker(5 * time.Minute)

    defer ticker.Stop()
    maxPassenger := 30
    passengers := make([]string, 0, maxPassenger)
    for {
       passenger := GetNewPassenger()
       if passenger != "" {
          passengers = append(passengers, passenger)
       } else {
          time.Sleep(1 * time.Second)
       }
       select {
       case <-ticker.C:
          Launch(passengers)
          passengers = []string{}
       default:
          if len(passengers) >= maxPassenger {
             Launch(passengers)
             passengers = []string{}
          }
       }
    }
}

func Launch(passengers []string) {
    for i := range passengers {
       fmt.Println(passengers[i], "發(fā)車了")
    }
}

func GetNewPassenger() string {
    return "乘客"
}

2.Ticker對外接口:

1)創(chuàng)建定時器:

源碼位置:src/time/tick.go

func NewTicker(d Duration) *Ticker {
    if d <= 0 {
       panic("non-positive interval for NewTicker")
    }
    // Give the channel a 1-element time buffer.
    // If the client falls behind while reading, we drop ticks
    // on the floor until the client catches up.
    c := make(chan Time, 1)
    t := (*Ticker)(unsafe.Pointer(newTimer(when(d), int64(d), sendTime, c, syncTimer(c))))
    t.C = c
    return t
}

2).停止定時器:

源碼位置:src/time/tick.go

// Stop turns off a ticker. After Stop, no more ticks will be sent.
// Stop does not close the channel, to prevent a concurrent goroutine
// reading from the channel from seeing an erroneous "tick".
func (t *Ticker) Stop() {
    if !t.initTicker {
       // This is misuse, and the same for time.Timer would panic,
       // but this didn't always panic, and we keep it not panicking
       // to avoid breaking old programs. See issue 21874.
       return
    }
    stopTimer((*Timer)(unsafe.Pointer(t)))
}

流程圖:

總流程圖:

3.簡單接口:

在有些場景下.啟動一個定時器后.該定時器永遠不會停止.比如定時輪詢?nèi)蝿?wù).此時可

以使用一個簡單的Tick函數(shù)來獲取定時器的管道.函數(shù)如下:

源碼位置:src/runtime/tick.go

func Tick(d Duration) <-chan Time {
    if d <= 0 {
       return nil
    }
    return NewTicker(d).C
}

從源碼可以看出其實是創(chuàng)建了一個Ticker.然后只返回了管道.并沒有返回ticker.所以

沒有辦法停止.

4.錯誤示例:

當(dāng)Ticker用于for循環(huán)時.很容易出現(xiàn)意想不到的資源泄漏問題.

示例:

func WrongTicker() {
    for  {
       select {
       case <-time.Tick(time.Second):
          log.Printf("resource leak!")
       }
    }
}

上面的代碼.select每次檢測case語句都會創(chuàng)建一個定時器.for循環(huán)又會不斷的執(zhí)行

select語句.系統(tǒng)里會有越來越多的定時器不斷地消耗CPU資源.最終CPU資源被耗

到此這篇關(guān)于Go進階之定時器Ticker的實現(xiàn)示例的文章就介紹到這了,更多相關(guān)Go 定時器Ticker內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

  • Go中strings的常用方法詳解

    Go中strings的常用方法詳解

    這篇文章主要介紹了Go中strings的常用方法詳解,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
    2020-03-03
  • Windows中Golang編譯運行緩慢的解決方法

    Windows中Golang編譯運行緩慢的解決方法

    Go語言編譯運行緩慢問題可能是由于Windows 11更新引入的PCManagerServiceStore進程導(dǎo)致的,該進程會強制檢查Go代碼編譯過程,消耗大量系統(tǒng)資源,下面就來介紹一下該問題的解決
    2025-08-08
  • Go 語言單例模式示例詳解

    Go 語言單例模式示例詳解

    這篇文章主要為大家介紹了Go 語言單例模式示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-10-10
  • golang 實現(xiàn)一個restful微服務(wù)的操作

    golang 實現(xiàn)一個restful微服務(wù)的操作

    這篇文章主要介紹了golang 實現(xiàn)一個restful微服務(wù)的操作,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-04-04
  • go語言實現(xiàn)字符串與其它類型轉(zhuǎn)換(strconv包)

    go語言實現(xiàn)字符串與其它類型轉(zhuǎn)換(strconv包)

    strconv包是Go語言標(biāo)準(zhǔn)庫的一部分,主要提供字符串與基本數(shù)據(jù)類型之間的轉(zhuǎn)換功能,使用strconv包可以方便地在不同類型之間進行轉(zhuǎn)換,滿足日常編程中的需求,感興趣的可以了解一下
    2024-10-10
  • Golang 基礎(chǔ)之函數(shù)使用(匿名遞歸閉包)實例詳解

    Golang 基礎(chǔ)之函數(shù)使用(匿名遞歸閉包)實例詳解

    這篇文章主要為大家介紹了Golang 基礎(chǔ)之函數(shù)使用(匿名遞歸閉包)實例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-10-10
  • 一文帶你使用Golang實現(xiàn)SSH客戶端

    一文帶你使用Golang實現(xiàn)SSH客戶端

    SSH?全稱為?Secure?Shell,是一種用于安全地遠程登錄到網(wǎng)絡(luò)上的其他計算機的網(wǎng)絡(luò)協(xié)議,本文主要為大家詳細介紹了如何使用?Golang?實現(xiàn)?SSH?客戶端,需要的可以參考下
    2023-11-11
  • Golang?中反射的應(yīng)用實例詳解

    Golang?中反射的應(yīng)用實例詳解

    這篇文章主要為大家介紹了Golang?中反射的應(yīng)用實例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-08-08
  • go語言channel實現(xiàn)多核并行化運行的方法

    go語言channel實現(xiàn)多核并行化運行的方法

    這篇文章主要介紹了go語言channel實現(xiàn)多核并行化運行的方法,實例分析了channel實現(xiàn)多核并行化運行的技巧,具有一定參考借鑒價值,需要的朋友可以參考下
    2015-03-03
  • Go中的fuzz模糊測試使用實戰(zhàn)詳解

    Go中的fuzz模糊測試使用實戰(zhàn)詳解

    這篇文章主要為大家介紹了Go中的fuzz模糊測試使用實戰(zhàn)詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2023-12-12

最新評論

鲁山县| 鲁山县| 文昌市| 临邑县| 博客| 即墨市| 上饶市| 沙田区| 鄂伦春自治旗| 朝阳市| 连山| 兴安盟| 东乡县| 遂川县| 东方市| 绥江县| 育儿| 阳西县| 遂溪县| 汉沽区| 德安县| 安宁市| 舟山市| 安阳县| 宝山区| 威海市| 崇义县| 普兰县| 县级市| 郧西县| 崇明县| 都昌县| 白沙| 宜章县| 明水县| 冷水江市| 珲春市| 酒泉市| 禄丰县| 南昌市| 禹州市|