From 79d01f5e1cbd5004d0ef1b7a04fadc0c73d9e997 Mon Sep 17 00:00:00 2001 From: Weizhen Wang Date: Wed, 1 Feb 2023 20:10:10 +0800 Subject: [PATCH] update Signed-off-by: Weizhen Wang --- resourcemanager/pooltask/task_manager.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/resourcemanager/pooltask/task_manager.go b/resourcemanager/pooltask/task_manager.go index d79bd4e8c2553..e87c222569792 100644 --- a/resourcemanager/pooltask/task_manager.go +++ b/resourcemanager/pooltask/task_manager.go @@ -61,12 +61,11 @@ type TaskStatusContainer[T any, U any, C any, CT any, TF Context[CT]] struct { // TaskManager is a manager that can control or watch the pool. type TaskManager[T any, U any, C any, CT any, TF Context[CT]] struct { task []TaskStatusContainer[T, U, C, CT, TF] - subTaskCnt atomic.Int32 running atomic.Int32 concurrency int32 } -// NewTaskManager create a new pooltask manager. +// NewTaskManager create a new pool task manager. func NewTaskManager[T any, U any, C any, CT any, TF Context[CT]](c int32) TaskManager[T, U, C, CT, TF] { task := make([]TaskStatusContainer[T, U, C, CT, TF], shard) for i := 0; i < shard; i++ {