本文介绍了gocron创建多个任务实例的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
我在使用这个包的脚本中遇到问题：
github/jasonlvhit/gocron在我找不到错误之后，我写了这个小小的测试脚本，导致执行了两倍的cronjobs按照预期：
func main（）{ for i：= 0;我< 3; i ++ { channel：= make（chan string） go taskCron（channel，i）} time.Sleep（time.Second * 5） gocron.Clear（） fmt.Println（stop this shit）} func任务（i int）{ fmt.Println（仍然在运行......，i）} func taskCron（channel chan string，i int）{ gocron.Every（4）.Seconds（）.Do任务，i） <-gocron.Start（）}运行它给了我这个输出：
- ▶运行* .go 仍在运行... 0 仍在运行... 0 仍在运行中... 1 仍在运行中... 1 仍在运行中... 2 仍在运行... 2 仍在运行... 0 仍在运行... 1 仍在运行... 2 停止此 有谁知道如何创建动态数量的gocron作业而不复制它们？感谢：）
解决方案确定显然
< -gocron.Start（）将启动已经启动的作业，以便解决我的问题，我必须将脚本更改为：
func main（）{ for i：= 0;我< 3; i ++ { taskCron（i）} channel2：= make（chan int） go startCron（channel2） time.Sleep（time。秒* 5） gocron.Clear（） fmt.Println（stop this）} func任务（i int）{ fmt.Println（仍在运行...，i）} func taskCron（i int）{ gocron.Every（4）.Seconds（）。 （任务，i）} func startCron（channel chan int）{ <-gocron.Start（）}我希望这可以帮助任何有同样问题的人！
I had a problem in a script using this package:
"github/jasonlvhit/gocron"I wrote this little testscript after I couldn't find a mistake and it resulted that there were twice as many cronjobs executed as intended:
func main() { for i := 0; i < 3; i++ { channel := make(chan string) go taskCron(channel, i) } time.Sleep(time.Second * 5) gocron.Clear() fmt.Println("stop this shit") } func task(i int) { fmt.Println("still running...", i) } func taskCron(channel chan string, i int) { gocron.Every(4).Seconds().Do(task, i) <-gocron.Start() }running it gave me this output:
——▶go run *.go still running... 0 still running... 0 still running... 1 still running... 1 still running... 2 still running... 2 still running... 0 still running... 1 still running... 2 stop thisDoes anyone know how I can create a dynamic amount of gocron jobs without duplicating them?
Thanks :)
解决方案Ok apparently
<-gocron.Start()will start jobs that were already startet again so to fix my issue, I had to change the script to this:
func main() { for i := 0; i < 3; i++ { taskCron(i) } channel2 := make(chan int) go startCron(channel2) time.Sleep(time.Second * 5) gocron.Clear() fmt.Println("stop this") } func task(i int) { fmt.Println("still running...", i) } func taskCron(i int) { gocron.Every(4).Seconds().Do(task, i) } func startCron(channel chan int) { <-gocron.Start() }I hope this helps anybody who had the same Problem!
更多推荐
gocron创建多个任务实例
发布评论