更新依赖

antlabs · Nov 6, 2022 · 9f3c434 · 9f3c434
1 parent 8a4da60
commit 9f3c434
Show file tree

Hide file tree

Showing 3 changed files with 24 additions and 3 deletions.
diff --git a/cronex_test.go b/cronex_test.go
@@ -2,6 +2,7 @@ package cronex
 
 import (
 	"fmt"
+	"sync/atomic"
 	"testing"
 	"time"
 
@@ -60,6 +61,7 @@ func Test_Cronex(t *testing.T) {
 	assert.NotEqual(t, count, 1, fmt.Sprintf("callback没有调用"))
 }
 
+// 测试下Next函数的时间可正确
 func Test_Cronex_ParseNext(t *testing.T) {
 
 	var schedule timer.Next
@@ -82,3 +84,22 @@ func Test_Cronex_ParseNext(t *testing.T) {
 		}
 	}
 }
+
+// 多次运行的例子
+func Test_Multiple(t *testing.T) {
+	cron := New()
+	count := int32(0)
+
+	cron.Start()
+	max := int32(10)
+	for i := int32(0); i < max; i++ {
+		cron.AddFunc("* * * * * *", func() {
+			fmt.Printf("Every Second")
+			atomic.AddInt32(&count, 1)
+		})
+	}
+
+	time.Sleep(time.Duration(1.1 * float64(time.Second)))
+	cron.Stop()
+	assert.Equal(t, max, count)
+}
diff --git a/go.mod b/go.mod
@@ -3,7 +3,7 @@ module github.com/antlabs/cronex
 go 1.19
 
 require (
-	github.com/antlabs/timer v0.0.8
+	github.com/antlabs/timer v0.0.9
 	github.com/stretchr/testify v1.6.1
 )
 

diff --git a/go.sum b/go.sum
@@ -1,7 +1,7 @@
 github.com/antlabs/stl v0.0.1 h1:TRD3csCrjREeLhLoQ/supaoCvFhNLBTNIwuRGrDIs6Q=
 github.com/antlabs/stl v0.0.1/go.mod h1:wvVwP1loadLG3cRjxUxK8RL4Co5xujGaZlhbztmUEqQ=
-github.com/antlabs/timer v0.0.8 h1:jXHDhsq04YT8+4G32PAfQzqifhoWsBTHQo93x/K4euc=
-github.com/antlabs/timer v0.0.8/go.mod h1:EuoyzCfnpVUmlRwsLvNo/uQuvqUm0CqJhT7FiqHWSdQ=
+github.com/antlabs/timer v0.0.9 h1:YW12W4YvwmDUUJ93BiLuSuoxdiXzPhwbJDYXGj0MTE8=
+github.com/antlabs/timer v0.0.9/go.mod h1:EuoyzCfnpVUmlRwsLvNo/uQuvqUm0CqJhT7FiqHWSdQ=
 github.com/davecgh/go-spew v1.1.0 h1:ZDRjVQ15GmhC3fiQ8ni8+OwkZQO4DARzQgrnXU1Liz8=
 github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=