佳木斯湛栽影视文化发展公司

主頁 > 知識(shí)庫 > golang定時(shí)器和超時(shí)的使用詳解

golang定時(shí)器和超時(shí)的使用詳解

熱門標(biāo)簽:鐵路電話系統(tǒng) Linux服務(wù)器 呼叫中心市場需求 AI電銷 網(wǎng)站排名優(yōu)化 地方門戶網(wǎng)站 百度競價(jià)排名 服務(wù)外包

我就廢話不多說了,大家還是直接看代碼吧~

func main() {
  var a chan string
  a =make(chan string)
  go sendDataTo(a)
  go timing()
  getAchan(10*time.Second,a)
}
func sendDataTo(a chan string) {
  for {
     a - "我是a通道的數(shù)據(jù)"
    time.Sleep(1e9 *3)
  }
}
//在一定時(shí)間內(nèi)接收不到a的數(shù)據(jù)則超時(shí)
func getAchan(timeout time.Duration, a chan string) {
  var after -chan time.Time
  loop:
  after = time.After(timeout)
  for{
    fmt.Println("等待a中的數(shù)據(jù),10秒后沒有數(shù)據(jù)則超時(shí)")
    select {
    case x :=- a:
      fmt.Println(x)
      goto loop
    case -after:
      fmt.Println("timeout.")
      return
    }
  }
}
func timing() {
  //定時(shí)器,10秒鐘執(zhí)行一次
  ticker := time.NewTicker(10 * time.Second)
  for {
    time := -ticker.C
    fmt.Println("定時(shí)器====>",time.String())
  }
}     

補(bǔ)充:golang的定時(shí)器NewTimer、NewTicker使用

廢話不多說,直接看代碼

package main 
import (
  "fmt"
  "sync"
  "time"
)
 
/**
*ticker只要定義完成,從此刻開始計(jì)時(shí),不需要任何其他的操作,每隔固定時(shí)間都會(huì)觸發(fā)。
*timer定時(shí)器,是到固定時(shí)間后會(huì)執(zhí)行一次
*如果timer定時(shí)器要每隔間隔的時(shí)間執(zhí)行,實(shí)現(xiàn)ticker的效果,使用 func (t *Timer) Reset(d Duration) bool
 */
func main() {
  var wg sync.WaitGroup
  wg.Add(2)
  //NewTimer 創(chuàng)建一個(gè) Timer,它會(huì)在最少過去時(shí)間段 d 后到期,向其自身的 C 字段發(fā)送當(dāng)時(shí)的時(shí)間
  timer1 := time.NewTimer(2 * time.Second)
 
  //NewTicker 返回一個(gè)新的 Ticker,該 Ticker 包含一個(gè)通道字段,并會(huì)每隔時(shí)間段 d 就向該通道發(fā)送當(dāng)時(shí)的時(shí)間。它會(huì)調(diào) 
  //整時(shí)間間隔或者丟棄 tick 信息以適應(yīng)反應(yīng)慢的接收者。如果d = 0會(huì)觸發(fā)panic。關(guān)閉該 Ticker 可      
  //以釋放相關(guān)資源。
  ticker1 := time.NewTicker(2 * time.Second)
 
  go func(t *time.Ticker) {
    defer wg.Done()
    for {
      -t.C
      fmt.Println("get ticker1", time.Now().Format("2006-01-02 15:04:05"))
    }
  }(ticker1)
 
  go func(t *time.Timer) {
    defer wg.Done()
    for {
      -t.C
      fmt.Println("get timer", time.Now().Format("2006-01-02 15:04:05"))
      //Reset 使 t 重新開始計(jì)時(shí),(本方法返回后再)等待時(shí)間段 d 過去后到期。如果調(diào)用時(shí)t   
      //還在等待中會(huì)返回真;如果 t已經(jīng)到期或者被停止了會(huì)返回假。
      t.Reset(2 * time.Second)
    }
  }(timer1) 
  wg.Wait()
}

運(yùn)行結(jié)果:

get ticker1 2018-09-07 22:44:29

get timer 2018-09-07 22:44:29

...

額外說明:

time.NewTicker定時(shí)觸發(fā)執(zhí)行任務(wù),當(dāng)下一次執(zhí)行到來而當(dāng)前任務(wù)還沒有執(zhí)行結(jié)束時(shí),會(huì)等待當(dāng)前任務(wù)執(zhí)行完畢后再執(zhí)行下一次任務(wù)。查閱go官網(wǎng)的文檔和經(jīng)過代碼驗(yàn)證。

time.NewTimer和Reset()函數(shù)實(shí)現(xiàn)定時(shí)觸發(fā),Reset()函數(shù)可能失敗,經(jīng)測(cè)試。

以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • Golang定時(shí)器的2種實(shí)現(xiàn)方法與區(qū)別
  • Golang 定時(shí)器(Timer 和 Ticker),這篇文章就夠了
  • Golang中定時(shí)器的陷阱詳解
  • 用golang實(shí)現(xiàn)一個(gè)定時(shí)器任務(wù)隊(duì)列實(shí)例
  • golang中定時(shí)器cpu使用率高的現(xiàn)象詳析
  • golang time包下定時(shí)器的實(shí)現(xiàn)方法
  • Golang 定時(shí)器的終止與重置實(shí)現(xiàn)

標(biāo)簽:銅川 湘潭 衡水 崇左 黃山 蘭州 仙桃 湖南

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《golang定時(shí)器和超時(shí)的使用詳解》,本文關(guān)鍵詞  ;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 收縮
    • 微信客服
    • 微信二維碼
    • 電話咨詢

    • 400-1100-266
    朔州市| 岱山县| 郓城县| 贵南县| 太保市| 西安市| 陇西县| 定安县| 和龙市| 昂仁县| 日土县| 沁水县| 崇仁县| 墨竹工卡县| 五寨县| 莱州市| 科尔| 延边| 民乐县| 法库县| 洛宁县| 潼南县| 会泽县| 扶风县| 昌都县| 新疆| 额尔古纳市| 柳州市| 双流县| 南澳县| 邹平县| 沭阳县| 闻喜县| 开阳县| 伊春市| 江川县| 饶平县| 大庆市| 郧西县| 平罗县| 喀什市|