该功能
time.NewTicker使通道发送定期消息,并提供了一种停止该消息的方法。使用它像这样(未经测试):
ticker := time.NewTicker(5 * time.Second)quit := make(chan struct{})go func() { for { select { case <- ticker.C: // do stuff case <- quit: ticker.Stop() return } } }()
您可以通过关闭
quit频道来停止工作人员:
close(quit)。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)