diff --git a/database-5_test.go b/database-5_test.go
index 399a61217eb0797f9508f0bff2479831f0644b30..febe77c1b7496c0e013b4fd56e21f795737ec5d9 100644
--- a/database-5_test.go
+++ b/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)
 
diff --git a/database-6_test.go b/database-6_test.go
index fee7927b2628f0a449caacfa16ced150f22582db..272a05a73f55b1a6c485994d492a7801f434cf9e 100644
--- a/database-6_test.go
+++ b/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)