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 Introduction

timing

A one-off timed task.

Thanks

robfig/cron

ChangeLog

[2018-05-22] Add Export

[2018-05-22] Renamed Tasks to TaskScheduler

[2019-02-23] Add task interface and can rewrite the logic

Quick Start

scheduler := NewScheduler()

scheduler.Start()

scheduler.AddFunc(time.Now().Unix()+1, func() {
	fmt.Println("one second after")
})

scheduler.AddTask(&Task{
	Job:FuncJob(func() {
    		fmt.Println("hello task2")
    }),
    RunTime:time.Now().Unix()+4,
})

//block it

add task

//10 seconds print one
scheduler.AddFuncSpace(10, func() {
	fmt.Println("one second after")
})


scheduler.AddTask(&Task{
	Job:FuncJob(func() {
    		fmt.Println("hello task")
    }),
    Spacing:4 //4 seconds send one
})

scheduler.AddTask(&Task{
	Job:FuncJob(func() {
    		fmt.Println("hello task2")
    }),
    Spacing:4 //4 seconds send one
    Number: 5 //exec 5 num go stop
})

scheduler.AddTask(&Task{
	Job:FuncJob(func() {
    		fmt.Println("hello task3")
    }),
    Spacing:4 //4 seconds send one
    EndTime: 1999999999   // at 199999999 go stop
})

task interface

If you need rewrite a new task

implement TaskInterface

type TaskInterface interface {
    TaskGetInterface
    TaskSetInterface
}

type TaskSetInterface interface {
    SetJob(job Job) TaskSetInterface
    SetRuntime(runtime int64) TaskSetInterface
    SetUuid(uuid string) TaskSetInterface
    SetSpacing(spacing int64) TaskSetInterface
    SetEndTime(endTime int64) TaskSetInterface
    SetRunNumber(number int) TaskSetInterface
}

type TaskGetInterface interface{
    RunJob()
    GetJob()  Job
    GetUuid() string
    GetRunTime() int64
    GetSpacing() int64
    GetEndTime() int64
    GetRunNumber() int
}

distributed the cron task

Example

Order expire, change order status => fail Timing of the send message

and more

timing's People

Contributors

Stargazers

Watchers

Forkers

fhaoquan weiyuefei hawleyhoo goldendeng daheige tank411 zyjblockchain n0mansky dingyuanhong 1340691923 mrs-cui

timing's Issues

TaskScheduler.run

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

有几处理应替换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)
}

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

起因

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

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

问题

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

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
	}
}()