[ADD] add test code

This commit is contained in:
zhoujunhao 2018-06-13 15:28:11 +08:00
parent a87ee3aa33
commit b1d2779e65

View File

@ -472,8 +472,8 @@ func (m *Manager) CollectingTasks() {
util.Exec(m.ctx, func() error {
for _, v := range m.queryResource {
v(m)
fmt.Println("xx",v(m))
}
fmt.Println("收集完毕")
return nil
}, time.Second*24)
@ -491,7 +491,8 @@ func (m *Manager) PerformTasks() {
}
}
}
fmt.Println("结束")
m.waiting = nil
fmt.Println("清理结束")
m.waiting = nil
return nil
}, time.Second*12)