关于golang:Golang定时器的终止与重置

13次阅读

共计 2091 个字符,预计需要花费 6 分钟才能阅读完成。

作者:ReganYue

起源:恒生 LIGHT 云社区

Golang:定时器的终止与重置

大家好,这里是致力变得优良的 R 君,这次咱们持续来进行 Golang 系列《让咱们一起 Golang》,昨日有读者对定时器的终止有疑难,本次咱们来理解 Golang 的定时器的终止与重置这也是一个比拟容易了解的知识点,一起来看一看吧!

先看上面一段代码:

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。


想向技术大佬们多多取经?开发中遇到的问题何处探讨?如何获取金融科技海量资源?

恒生 LIGHT 云社区,由恒生电子搭建的金融科技业余社区平台,分享实用技术干货、资源数据、金融科技行业趋势,拥抱所有金融开发者。

扫描下方小程序二维码,退出咱们!

正文完
 0