pkg/timerx
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改测试脚本

Browse Source
This commit is contained in:
Yun
2024-05-31 13:55:05 +08:00
parent 3719c417fb
commit 25b5008af9
1 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/main.go
+10 -10
View File
@@ -34,13 +34,13 @@ func cluster() {
client := getRedis()
ctx := context.Background()
cluster := timerx.InitCluster(ctx, client, "test")
err := cluster.AddSpace(ctx, "test_space", 1*time.Second, aa, "这是秒任务")
err := cluster.EverySpace(ctx, "test_space", 1*time.Second, aa, "这是秒任务")
fmt.Println(err)
err = cluster.AddMinute(ctx, "test_min", 15, aa, "这是分钟任务")
err = cluster.EveryMinute(ctx, "test_min", 15, aa, "这是分钟任务")
fmt.Println(err)
err = cluster.AddHour(ctx, "test_hour", 30, 0, aa, "这是小时任务")
err = cluster.EveryHour(ctx, "test_hour", 30, 0, aa, "这是小时任务")
fmt.Println(err)
err = cluster.AddDay(ctx, "test_day", 11, 0, 0, aa, "这是天任务")
err = cluster.EveryDay(ctx, "test_day", 11, 0, 0, aa, "这是天任务")
fmt.Println(err)
}
@@ -93,12 +93,12 @@ func re() {
ctx := context.Background()
cl := timerx.InitCluster(ctx, client, "kkkk")
cl.AddSpace(ctx, "test1", 1*time.Millisecond, aa, "data")
cl.AddSpace(ctx, "test2", 1*time.Millisecond, aa, "data")
cl.AddSpace(ctx, "test3", 1*time.Millisecond, aa, "data")
cl.AddSpace(ctx, "test4", 1*time.Millisecond, aa, "data")
cl.AddSpace(ctx, "test5", 1*time.Millisecond, aa, "data")
cl.AddSpace(ctx, "test6", 1*time.Millisecond, aa, "data")
cl.EverySpace(ctx, "test1", 1*time.Millisecond, aa, "data")
cl.EverySpace(ctx, "test2", 1*time.Millisecond, aa, "data")
cl.EverySpace(ctx, "test3", 1*time.Millisecond, aa, "data")
cl.EverySpace(ctx, "test4", 1*time.Millisecond, aa, "data")
cl.EverySpace(ctx, "test5", 1*time.Millisecond, aa, "data")
cl.EverySpace(ctx, "test6", 1*time.Millisecond, aa, "data")
select {}
}