Go
可以借助 time.After/time.Ticker
来实现延迟/定时触发器,主要原理是借助无缓冲 channel
无数据时读取操作会阻塞当前协程, Go
会在给定的时间后向 channel
中写入一些数据(当前时间),故阻塞的协程可以恢复运行,达到延迟或定时执行的功能。
延迟执行
time.After(d Duration)
好像不如直接用 time.Sleep(d Duration)
舒服,但存在即合理, time.After(d Duration)
的强大之处在于是基于 channel
的,可以在不同的协程间同步传递。
package main
import (
"time"
"fmt"
)
func main() {
fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
// create a nobuf channel and a goroutine `timer` will write it after 2 seconds
timeAfterTrigger = time.After(time.Second * 2)
// will be suspend but we have `timer` so will be not deadlocked
curTime, _ := <-timeAfterTrigger
// print current time
fmt.Println(curTime.Format("2006-01-02 15:04:05"))
}
定时执行
time.Ticker
的使用分两种场景:执行几次后退出 和 循环执行不退出,执行几次就退出的话我们需要需要回收 time.Ticker
。
执行若干次后退出需清理计时器
func main() {
// 创建一个计时器
timeTicker := time.NewTicker(time.Second * 2)
i := 0
for {
if i > 5 {
break
}
fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
i++
<-timeTicker.C
}
// 清理计时器
timeTicker.Stop()
}
循环执行不需要清理的话可以用更简便的 time.Tick()
方法
func main() {
// 创建一个计时器
timeTickerChan := time.Tick(time.Second * 2)
for {
fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
<-timeTickerChan
}
}
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网
猜你喜欢:- 触发器
- Oracle触发器详细讲解
- 窗口实用触发器:ContinuousEventTimeTrigger
- Oracle触发器用法实例详解
- 使用 Go 编写 PostgreSQL 触发器
- MySQL数据库之触发器
本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们。
程序员2010精华本
程序员杂志社 / 电子工业 / 2011-1 / 49.00元
《程序员(2010精华本)》主要内容:《程序员》创刊10年来,每年末编辑部精心打造的“合订本”已经形成一个品牌,得到广大读者的认可和喜爱。今年,《程序员》杂志内容再次进行了优化整合,除了每期推出的一个大型专题策划,各版块也纷纷以专题、策划的形式,将每月的重点进行了整合,让内容非常具有凝聚力,如专题篇、人物篇、实践篇等。另外杂志的版式、色彩方面也有了很大的飞跃,给读者带来耳目一新的阅读体验。一起来看看 《程序员2010精华本》 这本书的介绍吧!
HTML 压缩/解压工具
在线压缩/解压 HTML 代码
XML、JSON 在线转换
在线XML、JSON转换工具