修正worker状态信息

This commit is contained in:
屈轩
2018-12-22 17:05:37 +08:00
parent c35845f897
commit e768369181
+3 -1
View File
@@ -215,6 +215,7 @@ func (wm *SWorkerManager) DetachedWorkerCount() int {
type SWorkerManagerStates struct {
Name string
Backlog int
QueueCnt int
MaxWorkerCnt int
ActiveWorkerCnt int
DetachWorkerCnt int
@@ -224,7 +225,8 @@ func (wm *SWorkerManager) getState() SWorkerManagerStates {
state := SWorkerManagerStates{}
state.Name = wm.name
state.Backlog = wm.queue.Size()
state.Backlog = wm.backlog
state.QueueCnt = wm.queue.Size()
state.MaxWorkerCnt = wm.workerCount
state.ActiveWorkerCnt = wm.activeWorker.size()
state.DetachWorkerCnt = wm.detachedWorker.size()