opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-08-31 01:35:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(baremetal): TaskWorkerCount options not init

Browse Source
This commit is contained in:
Zexi Li
2021-10-25 11:55:43 +08:00
parent 771b992664
commit 8216e8e83b
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/baremetal/tasks/worker.go
+5 -5
View File
@@ -24,16 +24,16 @@ import (
"yunion.io/x/log"
"yunion.io/x/onecloud/pkg/appsrv"
"yunion.io/x/onecloud/pkg/baremetal/options"
"yunion.io/x/onecloud/pkg/mcclient/modules"
)
var baremetalTaskWorkerMan *appsrv.SWorkerManager
func init() {
baremetalTaskWorkerMan = appsrv.NewWorkerManager("BaremetalTaskWorkerManager", 4, 1024, false)
}
func GetWorkManager() *appsrv.SWorkerManager {
if baremetalTaskWorkerMan == nil {
baremetalTaskWorkerMan = appsrv.NewWorkerManager("BaremetalTaskWorkerManager", options.Options.TaskWorkerCount, 1024, false)
}
return baremetalTaskWorkerMan
}
@@ -45,7 +45,7 @@ func OnStop() {
}
func ExecuteTask(task ITask, args interface{}) {
baremetalTaskWorkerMan.Run(func() {
GetWorkManager().Run(func() {
executeTask(task, args)
}, nil, nil)
}