wdh-home
05ee541420
Some checks failed
CI / init (push) Has been cancelled
CI / Frontend node 18.16.0 (push) Has been cancelled
CI / Backend go (1.22) (push) Has been cancelled
CI / devops-test (1.22, 18.16.0) (push) Has been cancelled
CI / release-pr (push) Has been cancelled
CI / release-please (push) Has been cancelled
CI / devops-prod (1.22, 18.x) (push) Has been cancelled
CI / docker (push) Has been cancelled
73 lines
1.1 KiB
Go
73 lines
1.1 KiB
Go
package timer
|
|
|
|
import (
|
|
"fmt"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/assert"
|
|
)
|
|
|
|
var job = mockJob{}
|
|
|
|
type mockJob struct{}
|
|
|
|
func (job mockJob) Run() {
|
|
mockFunc()
|
|
}
|
|
|
|
func mockFunc() {
|
|
time.Sleep(time.Second)
|
|
fmt.Println("1s...")
|
|
}
|
|
|
|
func TestNewTimerTask(t *testing.T) {
|
|
tm := NewTimerTask()
|
|
_tm := tm.(*timer)
|
|
|
|
{
|
|
_, err := tm.AddTaskByFunc("func", "@every 1s", mockFunc, "测试mockfunc")
|
|
assert.Nil(t, err)
|
|
_, ok := _tm.cronList["func"]
|
|
if !ok {
|
|
t.Error("no find func")
|
|
}
|
|
}
|
|
|
|
{
|
|
_, err := tm.AddTaskByJob("job", "@every 1s", job, "测试job mockfunc")
|
|
assert.Nil(t, err)
|
|
_, ok := _tm.cronList["job"]
|
|
if !ok {
|
|
t.Error("no find job")
|
|
}
|
|
}
|
|
|
|
{
|
|
_, ok := tm.FindCron("func")
|
|
if !ok {
|
|
t.Error("no find func")
|
|
}
|
|
_, ok = tm.FindCron("job")
|
|
if !ok {
|
|
t.Error("no find job")
|
|
}
|
|
_, ok = tm.FindCron("none")
|
|
if ok {
|
|
t.Error("find none")
|
|
}
|
|
}
|
|
{
|
|
tm.Clear("func")
|
|
_, ok := tm.FindCron("func")
|
|
if ok {
|
|
t.Error("find func")
|
|
}
|
|
}
|
|
{
|
|
a := tm.FindCronList()
|
|
b, c := tm.FindCron("job")
|
|
fmt.Println(a, b, c)
|
|
}
|
|
}
|