fix data race

4 years ago · a3d7474ae0
parent 6fdee77fa9
commit a3d7474ae0
1 changed files with 1 additions and 3 deletions
--- a/core/executors/periodicalexecutor.go
+++ b/core/executors/periodicalexecutor.go
@ -139,9 +139,7 @@ func (pe *PeriodicalExecutor) executeTasks(tasks interface{}) bool {
 	pe.wgBarrier.Guard(func() {
 		pe.waitGroup.Add(1)
 	})
-	defer pe.wgBarrier.Guard(func() {
+	defer pe.waitGroup.Done()
 		pe.waitGroup.Done()
 	})
 	ok := pe.hasTasks(tasks)
 	if ok {