From d7b8d8e5ed1a8b132d55649e89aa0648a90c1ec4 Mon Sep 17 00:00:00 2001 From: Volker Schukai <volker.schukai@schukai.com> Date: Tue, 19 Mar 2024 20:00:21 +0100 Subject: [PATCH] fix: race --- database-5_test.go | 2 ++ database-6_test.go | 6 +++++- 2 files changed, 7 insertions(+), 1 deletion(-) diff --git a/database-5_test.go b/database-5_test.go index 399a612..febe77c 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 fee7927..272a05a 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) -- GitLab