lwl1989 / timing Goto Github PK

View Code? Open in Web Editor NEW

57.0 2.0 11.0 46 KB

一个适用于一次性或者需要重复性任务的执行器，可配合常驻服务实现自动执行定时任务(非类linux CronTab)

License: MIT License

Go 100.00%

crontab timer ticket

timing's Issues

task内 panic时会恐慌，报错：使用了关闭的channel

复现代码：

task := &timing2.Task{
Uuid: "uuid",
Job: timing2.GetJob(func() {
panic("err")
}),
RunTime: time.Now().Unix() + 90,
}

异常代码处：
job.go func (j *taskJob) run()

原因是 defer的顺序是先进后出，原代码会先触发 j.done <- true 然后进行了 finish的逻辑，代码应改为：

defer func() {
	if !isPanic {
		j.done <- true
	}
}()

defer func() {
	if x := recover(); x != nil {
		err := errors.Errorf("job error with panic:%v", x)
		j.err <- err
		isPanic = true
		return
	}
}()

TaskScheduler.run

你好，在TaskScheduler.run 方法中，for循环存在的意义是什么？最后加了break，可见for循环只执行了一次

自定义任务，如何传入带参函数

起因

今天更新了一下包，发现你的包改动很大，导致之前写的代码无法编译通过。

还有就是之前你的包，似乎有点bug，就是我指定RunTime,Spacing,EndTime，
发现并没有按照Spacing间隔执行，往往是只执行一次就没了。
但是指定Number就没有这个问题。

问题

我需要传入一个s参数，如何避免上述写法?

有几处理应替换addTask方法变为AddTask方法

还是有些问题哦老哥

timer.go文件里面的addTask方法没有处理runtime

timer.go文件有几处理应替换addTask方法变为AddTask方法

func (scheduler *TaskScheduler) AddFuncSpaceNumber(spaceTime int64, number int, f func()) {
	task := getTaskWithFuncSpacingNumber(spaceTime, number, f)
	scheduler.AddTask(task)
}
//add spacing time job to list with endTime
func (scheduler *TaskScheduler) AddFuncSpace(spaceTime int64, endTime int64, f func()) {
	task := getTaskWithFuncSpacing(spaceTime, endTime, f)
	scheduler.AddTask(task)
}

//add func to list
func (scheduler *TaskScheduler) AddFunc(unixTime int64, f func()) {
	task := getTaskWithFunc(unixTime, f)
	scheduler.AddTask(task)
}

lwl1989 / timing Goto Github PK

timing's Issues

task内 panic时会恐慌，报错：使用了关闭的channel

TaskScheduler.run

自定义任务，如何传入带参函数

起因

问题

有几处理应替换addTask方法变为AddTask方法

老哥bug一大堆编译都过不了你确定能用？

Recommend Projects

React

Vue.js

Typescript

TensorFlow

Django

Laravel

D3

Recommend Topics

javascript

web

server

Machine learning

Visualization

Game

Recommend Org

Facebook

Microsoft

Google

Alibaba

D3

Tencent