use goroutine pool deal sc.taskUnschedulable

Signed-off-by: 张建宇 <[email protected]>

pkg/scheduler/cache/cache.go

@@ -74,6 +74,8 @@ import (
 const (
 	// default interval for sync data from metrics server, the value is 30s
 	defaultMetricsInternal = 30 * time.Second
+
+	taskUpdaterWorker = 16
 )
 
 // defaultIgnoredProvisioners contains provisioners that will be ignored during pod pvc request computation and preemption.
@@ -1487,13 +1489,12 @@ func (sc *SchedulerCache) RecordJobStatusEvent(job *schedulingapi.JobInfo, updat
 	// Update podCondition for tasks Allocated and Pending before job discarded
 	for _, status := range []schedulingapi.TaskStatus{schedulingapi.Allocated, schedulingapi.Pending, schedulingapi.Pipelined} {
 		statusTasks := job.TaskStatusIndex[status]
-		workerNum := 16
 		taskInfos := make([]*schedulingapi.TaskInfo, 0, len(statusTasks))
 		for _, task := range statusTasks {
 			taskInfos = append(taskInfos, task)
 		}
 
-		workqueue.ParallelizeUntil(context.TODO(), workerNum, len(taskInfos), func(index int) {
+		workqueue.ParallelizeUntil(context.TODO(), taskUpdaterWorker, len(taskInfos), func(index int) {
 			taskInfo := taskInfos[index]
 
 			// The pod of a scheduling gated task is given