Skip to content

Commit

Permalink
update
Browse files Browse the repository at this point in the history
Signed-off-by: Weizhen Wang <[email protected]>
  • Loading branch information
hawkingrei committed Feb 1, 2023
1 parent 837a6d0 commit 79d01f5
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions resourcemanager/pooltask/task_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -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++ {
Expand Down

0 comments on commit 79d01f5

Please sign in to comment.