fix comment

pingcap · Dec 18, 2023 · 3781105 · 3781105
1 parent c442754
commit 3781105
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/disttask/framework/taskexecutor/slot.go b/pkg/disttask/framework/taskexecutor/slot.go
@@ -63,5 +63,8 @@ func (sm *slotManager) unReserve(taskID int64) {
 
 // canReserve is used to check whether the instance has enough slots to run the task.
 func (sm *slotManager) canReserve(task *proto.Task) bool {
+	sm.Lock()
+	defer sm.Unlock()
+
 	return sm.available >= task.Concurrency
 }