fix data race

zeromicro · Aug 14, 2020 · a3d7474 · a3d7474
1 parent 6fdee77
commit a3d7474
Showing 1 changed file with 1 addition and 3 deletions.
diff --git 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() {
-		pe.waitGroup.Done()
-	})
+	defer pe.waitGroup.Done()
 
 	ok := pe.hasTasks(tasks)
 	if ok {