refactor: Server.schedule 复用 time.Now 的值

server.go

@@ -88,15 +88,15 @@ func (s *Server) schedule(ctx context.Context) {
 	sortJobs(s.jobs) // 按执行时间进行排序
 
 	var dur time.Duration
+	now := time.Now()
 
 	if len(s.jobs) == 0 || s.jobs[0].Next().IsZero() {
 		dur = time.Minute
 	} else {
-		dur = time.Until(s.jobs[0].Next())
+		dur = s.jobs[0].Next().Sub(now)
 	}
 
-	// dur > 0 表示没有需要立即执行的，根据最早的一条任务做一个计时器。
-	if dur > 0 {
+	if dur > 0 { // dur > 0 表示没有需要立即执行的，根据最早的一条任务做一个计时器。
 		timer := time.NewTimer(dur)
 		for {
 			select {
@@ -111,7 +111,6 @@ func (s *Server) schedule(ctx context.Context) {
 		}
 	}
 
-	now := time.Now()
 	for _, j := range s.jobs {
 		if next := j.Next(); next.After(now) || next.IsZero() {
 			break

server_test.go

@@ -147,7 +147,7 @@ func TestServer_Serve_zero(t *testing.T) {
 	}
 }
 
-// 一个运行时间超过一个时间间隔的任务
+// 运行时间超过一个时间间隔的任务
 func TestServer_Serve_delay(t *testing.T) {
 	a := assert.New(t, false)
 	srv := NewServer(nil, nil, nil)
@@ -179,19 +179,19 @@ func TestServer_Serve_delay(t *testing.T) {
 	time.Sleep(5 * time.Second)
 	cancel()
 
-	a.NotEmpty(tickers1)
-	a.NotEmpty(tickers2)
+	a.NotEmpty(tickers1).
+		NotEmpty(tickers2)
 	for i := 1; i < len(tickers1); i++ {
 		prev := tickers1[i-1].Unix()
 		curr := tickers1[i].Unix()
 		delta := math.Abs(float64(curr - prev)) // 缺失一次执行，应该介于 4-6 之间？
-		a.True(delta >= 4 && delta < 6, "%d != %d", prev, curr)
+		a.True(delta >= 4 && delta < 6, "v1=%d, v2=%d", prev, curr)
 	}
 	for i := 1; i < len(tickers2); i++ {
 		prev := tickers2[i-1].Unix()
 		curr := tickers2[i].Unix()
-		delta := math.Abs(float64(curr - prev))
-		a.True(delta <= 3, "%d != %d", prev, curr)
+		delta := math.Abs(float64(curr - prev)) // 缺失一次执行，应该介于 4-6 之间？
+		a.True(delta >= 4 && delta < 6, "v1=%d, v2=%d", prev, curr)
 	}
 }