()
| 54 | } |
| 55 | |
| 56 | func (this *ModuleWorkerPool) Start() { |
| 57 | for _, m := range this.modules { |
| 58 | go func(m Module) { m.(ModuleWoker).Run(&wait_close) }(m) |
| 59 | } |
| 60 | } |
| 61 | |
| 62 | func (this *ModuleWorkerPool) ForEachModule(f func(m Module)) { |
| 63 | for _, v := range this.modules { |