go語言設(shè)置定時器的方法-創(chuàng)新互聯(lián)

小編給大家分享一下go語言設(shè)置定時器的方法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

創(chuàng)新互聯(lián)長期為千余家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊從業(yè)經(jīng)驗10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為嘉祥企業(yè)提供專業(yè)的網(wǎng)站設(shè)計制作、網(wǎng)站設(shè)計，嘉祥網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。

go語言設(shè)置定時器的方法：1、通過“time.NewTicker()”方法創(chuàng)建，其中ticker會按照設(shè)定的間隔時間觸發(fā)；2、通過“time.NewTimer()”方法創(chuàng)建，其中timer只會執(zhí)行一詞；3、使用“After()”來創(chuàng)建。

Go語言中定時器的使用

GO語言在time包中提供了三種定時器的使用方式：

1.第一種：ticker

// A Ticker holds a channel that delivers `ticks' of a clock
// at intervals.
type Ticker struct {
	C <-chan Time // The channel on which the ticks are delivered.
	r runtimeTimer
}

通過time.NewTicker() 創(chuàng)建，這種類型，ticker會不斷的按照設(shè)定的間隔時間觸發(fā)，除非主動終止運(yùn)行。

2.第二種：timer

// The Timer type represents a single event.
// When the Timer expires, the current time will be sent on C,
// unless the Timer was created by AfterFunc.
// A Timer must be created with NewTimer or AfterFunc.
type Timer struct {
	C <-chan Time
	r runtimeTimer
}

通過 time.NewTimer() 創(chuàng)建，這種類型，timer只會執(zhí)行一次，當(dāng)然，可以在執(zhí)行完以后通過調(diào)用timer.Reset() 讓定時器再次工作，并可以更改時間間隔。

3.第三種：After()

// After waits for the duration to elapse and then sends the current time
// on the returned channel.
// It is equivalent to NewTimer(d).C.
// The underlying Timer is not recovered by the garbage collector
// until the timer fires. If efficiency is a concern, use NewTimer
// instead and call Timer.Stop if the timer is no longer needed.
func After(d Duration) <-chan Time {
	return NewTimer(d).C
}

從代碼可以看到，After()其實是Timer的一個語法糖。

---

下面通過代碼演示一下三種方式的使用：

1.Ticker

ticker := time.NewTicker(time.Second * 1) // 運(yùn)行時長
    ch := make(chan int)
    go func() {
        var x int
        for x < 10 {
            select {
            case <-ticker.C:
                x++
                fmt.Printf("%d\n", x)
            }
        }
        ticker.Stop()
        ch <- 0
    }()
    <-ch                                    // 通過通道阻塞，讓任務(wù)可以執(zhí)行完指定的次數(shù)。

該ticker每1秒觸發(fā)一次，即ticker.C中每一秒會有一個內(nèi)容加入，最后通過向ch中寫入數(shù)字，讓程序解除阻塞，繼續(xù)執(zhí)行。

2.Timer

timer := time.NewTimer(time.Second * 1) // timer 只能按時觸發(fā)一次，可通過Reset()重置后繼續(xù)觸發(fā)。
    go func() {
        var x int
        for {
            select {
            case <-timer.C:
                x++
                fmt.Printf("%d,%s\n", x, time.Now().Format("2006-01-02 15:04:05"))
                if x < 10 {
                    timer.Reset(time.Second * 2)
                } else {
                    ch <- x
                }
            }
        }
    }()
    <-ch

3.After()

// 阻塞一下，等待主進(jìn)程結(jié)束
    tt := time.NewTimer(time.Second * 10)
    <-tt.C
    fmt.Println("over.")

    <-time.After(time.Second * 4)
    fmt.Println("再等待4秒退出。tt 沒有終止，打印出 over 后會看見在繼續(xù)執(zhí)行...")
    tt.Stop()
    <-time.After(time.Second * 2)
    fmt.Println("tt.Stop()后， tt 仍繼續(xù)執(zhí)行，只是關(guān)閉了 tt.C 通道。")

4.我們可以利用這些基本的方法，設(shè)計自己的定時任務(wù)管理。

type jobFunc2 func(j *job)

type job struct {
    jf     jobFunc2
    params map[string]interface{}
    ch     chan int
}

func NewJob() *job {
    return &job{
        params: make(map[string]interface{}),
        ch:     make(chan int),
    }
}

func (j *job) Run(t time.Duration) {
    ticker := time.NewTicker(time.Second * t)
    go func() {
        for {
            select {
            case <-ticker.C:
                j.jf(j)
            case <-j.ch:
                fmt.Println("收到結(jié)束指令")
                ticker.Stop()
                break
            }
        }
    }()

}

func main() {
    j := NewJob()
    j.jf = func(jj *job) {
        fmt.Println("定時任務(wù)執(zhí)行...", time.Now().Format("15:04:05 2006-02-01"), jj.params)
    }
    j.params["p1"] = "第一個參數(shù)"
    j.params["p2"] = 100
    j.Run(1)

    // 阻塞一下，等待主進(jìn)程結(jié)束
    tt := time.NewTimer(time.Second * 10)
    <-tt.C
    fmt.Println("over.")

    <-time.After(time.Second * 4)
    fmt.Println("再等待4秒退出。tt 沒有終止，打印出 over 后會看見在繼續(xù)執(zhí)行...")
    tt.Stop()
    <-time.After(time.Second * 2)
    fmt.Println("tt.Stop()后， tt 仍繼續(xù)執(zhí)行，只是關(guān)閉了 tt.C 通道。")
}

部分執(zhí)行結(jié)果截圖：

最后補(bǔ)充一下，通過channel去終止任務(wù)的執(zhí)行。

// 阻塞一下，等待主進(jìn)程結(jié)束
    tt := time.NewTimer(time.Second * 10)
    <-tt.C
    fmt.Println("over.")

    <-time.After(time.Second * 4)
    fmt.Println("再等待4秒退出。tt 沒有終止，打印出 over 后會看見在繼續(xù)執(zhí)行...")
    tt.Stop()
    <-time.After(time.Second * 2)
    fmt.Println("tt.Stop()后， tt 仍繼續(xù)執(zhí)行，只是關(guān)閉了 tt.C 通道。")
    j.ch <- 0
    <-time.After(time.Second * 2)
    fmt.Println("又等了2秒鐘...這兩秒鐘可以看到 tt 沒干活了...")

在GO語言編寫中，要熟練使用channel。

以上是“go語言設(shè)置定時器的方法”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對大家有所幫助，如果還想學(xué)習(xí)更多知識，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

文章題目：go語言設(shè)置定時器的方法-創(chuàng)新互聯(lián)
轉(zhuǎn)載注明：http://bm7419.com/article8/cedpop.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站排名、做網(wǎng)站、微信小程序、移動網(wǎng)站建設(shè)、Google、搜索引擎優(yōu)化

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)