golang 中timer,ticker 的使用

用户7798898

发布于 2020-09-27 16:30:10

6450

发布于 2020-09-27 16:30:10

写一个程序， 5s, 10s后能定时执行一个任务，同时能不停的处理来的消息。

package main

import (
	"fmt"
	"time"
)

func main() {

	input := make(chan interface{})

	//producer - produce the messages
	go func() {
		for i := 0; i < 5; i++ {
			input <- i
		}
		input <- "hello, world"
	}()

	t1 := time.NewTimer(time.Second * 5)
	t2 := time.NewTimer(time.Second * 10)

	for {
		select {
		//consumer - consume the messages
		case msg := <-input:
			fmt.Println(msg)

		case <-t1.C:
			println("5s timer")
			t1.Reset(time.Second * 5)

		case <-t2.C:
			println("10s timer")
			t2.Reset(time.Second * 10)
		}
	}
}

写出上面这段程序的目的是从 input channel 持续接收消息加以处理，同时希望每过5秒钟和每过10秒钟就分别执行一个定时任务

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

原始发表：2017-07-02 ，如有侵权请联系 cloudcommunity@tencent.com 删除

channel