Timing task manager based on red black tree in memory
- support task function call, and event notifications
- support task that executes once or several times
- support task cancel which added
- fault isolation
- 100k/s operation
last indicator may not be available on the cloud server,see more test code
var (
myClock = NewClock()
jobFunc = func() {
fmt.Println("schedule once")
}
)
//add a task that executes once,interval 100 millisecond
myClock.AddJobWithInterval(time.Duration(100*time.Millisecond), jobFunc)
//wait a second,watching
time.Sleep(1 * time.Second)
//Output:
//
//schedule oncefunc ExampleClock_AddJobRepeat() {
var (
myClock = NewClock()
)
//define a repeat task
fn := func() {
fmt.Println("schedule repeat")
}
//add in clock,execute three times,interval 200 millisecond
_, inserted := myClock.AddJobRepeat(time.Duration(time.Millisecond*200), 3, fn)
if !inserted {
log.Println("failure")
}
//wait a second,watching
time.Sleep(time.Second)
//Output:
//
//schedule repeat
//schedule repeat
//schedule repeat
}func ExampleClock_RmJob(){
var (
myClock = NewClock()
count int
jobFunc = func() {
count++
fmt.Println("do ",count)
}
)
//创建任务，间隔1秒，执行两次
job, _ := myClock.AddJobRepeat(time.Second*1,2, jobFunc)
//任务执行前，撤销任务
time.Sleep(time.Millisecond*500)
job.Cancel()
//等待3秒，正常情况下，事件不会再执行
time.Sleep(3 * time.Second)
//Output:
//
//
}
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent