fix: race

database-5_test.go

@@ -43,7 +43,9 @@ func TestWriteToDB5(t *testing.T) {
 	err = mgr.CancelJobSchedule("jobSameID")
 	assert.Nil(t, err)
 
+	mgr.mu.Lock()
 	err = mgr.jobSyncer.Stop()
+	mgr.mu.Unlock()
 
 	assert.Nil(t, err)
 

database-6_test.go

@@ -47,12 +47,16 @@ func TestWriteToDB6(t *testing.T) {
 		err = mgr.ScheduleJob(job, scheduler)
 		assert.Nil(t, err)
 
+		mgr.mu.Lock()
 		mgr.jobSyncer.AddJob(job)
+		mgr.mu.Unlock()
 		time.Sleep(10 * time.Millisecond)
 
 	}
 
-	mgr.jobSyncer.Stop()
+	mgr.mu.Lock()
+	_ = mgr.jobSyncer.Stop()
+	mgr.mu.Unlock()
 
 	time.Sleep(2 * time.Second)