Golang 定时器的终止与重置实现

昨日有读者对定时器的终止有疑问,今天我们来聊一聊定时器的终止与重置吧!

定时器是一种通过设置一项任务,在未来的某个时刻执行该任务的机制。

定时器的种类通常只有两种,一种是只执行一次的延时模式,一种是每隔一段时间执行一次的间隔模式。

在现代编程语言中,定时器几乎是标配。除了设置定时器外,还需要有提供定时器的方法。

比如在 JavaScript 中,提供了 setTimeout、setInterval、clearTimeout 和 clearInterval 四个 API,相比较而言是比较简单的。Go 语言中定时器的 API 就比较完善,所有的 API 都在 time 包中。

先看下面一段代码:

func main() {
    timer := time.NewTimer(3 * time.Second)
    fmt.Println(time.Now(),"炸弹将于3秒后引爆")
​
​
    timer.Stop()
    fmt.Println("定时炸弹已拆除,定时器失效")
​

    t := <-timer.C
    fmt.Println("炸弹引爆于",t)
}

先来看看运行结果

2021-08-25 10:08:34.706412 +0800 CST m=+0.023017601 炸弹将于3秒后引爆
定时炸弹已拆除,定时器失效
fatal error: all goroutines are asleep - deadlock!

我们可以趁定时器时间未到而使用Stop来将定时器终止,如果定时器已被叫停,其时间管道永远读不出数据了,如果强制读取,就会出现死锁。因为使用Stop就是停止往管道里面写数据了,或者可以这样说,就是管道里面的数据已经读完了,使用time.NewTimer(3 * time.Second)就是往管道里面写数据。

我们在来看一个有趣的例子。

func main()  {
    timer := time.NewTimer(1 * time.Second)
    fmt.Println(time.Now())
​
    time.Sleep(2 * time.Second)
    fmt.Println(time.Now())
​
    timer.Reset(10*time.Second)
    fmt.Println("炸弹引爆于",<-timer.C)
}

现在,思考一下,炸弹是什么时候引爆的!

想知道答案吗?不要着急,不要着急,休息,休息一会儿,答案马上揭晓

我们来看看运行结果吧:

2021-08-25 10:15:16.8406335 +0800 CST m=+0.014999801
2021-08-25 10:15:18.906213 +0800 CST m=+2.080579301
炸弹引爆于 2021-08-25 10:15:17.8522233 +0800 CST m=+1.026589601

是不是和你想的一样?如果不是,没关系,听我细细道来。
因为time.sleep()是让主协程睡大觉,而timer.C读的那条管道的协程是独立的。所以你让主协程睡大觉并不会影响定时器的计时,就相当于一个定时炸弹要引爆了,你马上把手表的时间往后调,但是定时炸弹上的数字时间不会因为手表上的时间往后调而往后调。

诶!这时你会说我不是重置了吗?
但是定时器超时了,那么重置就不起作用了,你想一想,定时炸弹都爆炸了,你去重置还有效吗?
如果我们将定时器的时间调到3秒,就是这样:

timer := time.NewTimer(3 * time.Second)

那么输出结果会怎样?

2021-08-25 10:26:21.1299417 +0800 CST m=+0.020983301
2021-08-25 10:26:23.2191128 +0800 CST m=+2.110154401
炸弹引爆于 2021-08-25 10:26:33.227692 +0800 CST m=+12.118733601

设置定时器后2秒,主协程才执行到Reset(),所以炸弹是在设置定时器12秒后才爆炸的。
有趣的是,当我查看Reset()的源码时,发现了这样一段注释:

// Reset should be invoked only on stopped or expired timers with drained channels.
// If a program has already received a value from t.C, the timer is known
// to have expired and the channel drained, so t.Reset can be used directly.
// If a program has not yet received a value from t.C, however,
// the timer must be stopped and—if Stop reports that the timer expired
// before being stopped—the channel explicitly drained:
//
//  if !t.Stop() {
//      <-t.C
//  }
//  t.Reset(d)

根据我的理解,大意是这样的,如果计时器已经过期,并且t.C已经被读完了,那么可以直接使用Reset。而如果程序Reset之前未从t.C中读取过值的话,就需要调用Stop来结束定时器,才能使用reset。

到此这篇关于Golang 定时器的终止与重置实现的文章就介绍到这了,更多相关Golang 定时器终止与重置内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Golang定时器的2种实现方法与区别

    不得不说,golang的sdk做了太多的东西,定时器在golang里实现起来非常的简单 两种方式 NewTicker() NewTimer() 代码如下 NewTicker() 方式 func foo() { fmt.Println("foo() start.") time.Sleep(time.Second * 3) fmt.Println("foo() end.") } func TestTicker(t *testing.T) { ticker := time

  • golang time包下定时器的实现方法

    golang time包 和python一样,golang时间处理还是比较方便的,以下介绍了golang 时间日期,相关包 "time"的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍. 时间戳 当前时间戳 fmt.Println(time.Now().Unix()) # 1389058332 str格式化时间 当前格式化时间 fmt.Println(time.Now().Format("2006-01-02 15:04:05")) // 这

  • 用golang实现一个定时器任务队列实例

    很有幸得到公司信任,采用新的语言进行一些底层服务的开发,在实现功能的同时,也获得了一些感悟,因此在这记录一下,方便自己查看也可以共享给大家. golang中定时器 golang中提供了2种定时器timer和ticker(如果JS很熟悉的话应该会很了解),分别是一次性定时器和重复任务定时器. 一般用法: func main() { input := make(chan interface{}) //producer - produce the messages go func() { for i

  • Golang 定时器(Timer 和 Ticker),这篇文章就够了

    定时器是什么 Golang 原生 time 包下可以用来执行一些定时任务或者是周期性的任务的一个工具 本文基于 Go 1.14,如果以下文章有哪里不对或者问题的地方,欢迎讨论学习 定时器的日常使用 Timer 相关 func NewTimer(d Duration) *Timer func (t *Timer) Reset(d Duration) bool func (t *Timer) Stop() bool func After(d Duration) <-chan Time func Af

  • Golang中定时器的陷阱详解

    前言 在业务中,我们经常需要基于定时任务来触发来实现各种功能.比如TTL会话管理.锁.定时任务(闹钟)或更复杂的状态切换等等.百纳网主要给大家介绍了关于Golang定时器陷阱的相关内容,所谓陷阱,就是它不是你认为的那样,这种认知误差可能让你的软件留下隐藏Bug.刚好Timer就有3个陷阱,我们会讲 1)Reset的陷阱和 2)通道的陷阱, 3)Stop的陷阱与Reset的陷阱类似,自己探索吧. 下面话不多说了,来一起看看详细的介绍吧 Reset的陷阱在哪 Timer.Reset()函数的返回值是

  • golang定时器和超时的使用详解

    我就废话不多说了,大家还是直接看代码吧~ 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通道的数据" time.Sleep(1e9 *3) } } //在一定时间内接收不到a的数据则超时 func getAcha

  • golang中定时器cpu使用率高的现象详析

    前言: 废话少说,上线一个用golang写的高频的任务派发系统,上线跑着很稳定,但有个缺点就是当没有任务的时候,cpu的消耗也在几个百分点. 平均值在3%左右的cpu使用率.你没有任务的时候,cpu还跑到3%,这个说不过去呀.通过查看进程pidstat捕获得知,system系统的cpu消耗也不少. sys的cpu占用率高一般是由于大量的syscall系统调用引起的-. 下面的截图是用strace统计出来的系统调用-. 我们发现  futex 和 pselect6 的syscall非常的多-. 

  • Golang 定时器的终止与重置实现

    昨日有读者对定时器的终止有疑问,今天我们来聊一聊定时器的终止与重置吧! 定时器是一种通过设置一项任务,在未来的某个时刻执行该任务的机制. 定时器的种类通常只有两种,一种是只执行一次的延时模式,一种是每隔一段时间执行一次的间隔模式. 在现代编程语言中,定时器几乎是标配.除了设置定时器外,还需要有提供定时器的方法. 比如在 JavaScript 中,提供了 setTimeout.setInterval.clearTimeout 和 clearInterval 四个 API,相比较而言是比较简单的.G

  • golang 一次性定时器Timer用法及实现原理详解

    目录 前言 Timer timer结构体 创建定时器 停止定时器 重置定时器 实现原理 数据结构 runtimeTimer 创建Timer 停止Timer 重置Timer 前言 定时器在Go语言应用中使用非常广泛,Go语言的标准库里提供两种类型的计时器,一种是一次性的定时器Timer,另外一种是周期性的定时器Ticker.本文主要来看一下Timer的用法和实现原理,需要的朋友可以参考以下内容,希望对大家有帮助. Timer Timer是一种单一事件的定时器,即经过指定的时间后触发一个事件,因为T

  • golang 定时任务方面time.Sleep和time.Tick的优劣对比分析

    golang 写循环执行的定时任务,常见的有以下三种实现方式 1.time.Sleep方法: for { time.Sleep(time.Second) fmt.Println("我在定时执行任务") } 2.time.Tick函数: t1:=time.Tick(3*time.Second) for { select { case <-t1: fmt.Println("t1定时器") } } 3.其中Tick定时任务 也可以先使用time.Ticker函数获取

  • 计算两个字符串最大公有子串

    背景 对算法一直应用的比较少,最近看到一些典型的算法想练练手,想看看到底有多么让人讨厌.其实发现算法都有一定的套路,一般并不是临时凭空想出来的,大都建立在一些已经存在的经典算法知识以及数据结构上.换句话来说,如果某些玩法之前未接触过,那么让你在短时间内临时想出来还是有一定难度的.这有点类似项目经验,如果曾经做过一个CRM系统,下次再碰到它时你就轻松很多,如果你挑战的是一个你从未遇到过的系统,你只能凭已有知识去强吃. 计算两个字符串最大公共子串 这个也是经常遇到到,给出两个任意长度的字符串,输出最

  • 原生JS+CSS实现炫酷重力模拟弹跳系统的登录页面

    今天小编把之前保存的js特效视频看了一遍,跟着视频敲了敲嘻嘻,用原生js实现一个炫酷的登录页面.怎么个炫酷法呢,看看下面的图片大家就知道啦. 效果图: 不过在看代码之前呢,大家先和小颖看看css中的opacity.transition.box-shadow这三个属性. 1.opacity CSS3 opacity 属性 实例 设置一个div元素的透明度级别: div { opacity:0.5; } 在此页底部有更多的例子. 浏览器支持 Internet ExplorerFirefoxOpera

随机推荐