()
| 74 | } |
| 75 | |
| 76 | func Start() { |
| 77 | module_map.Range(func(k interface{}, m interface{}) bool { |
| 78 | go func(m interface{}) { m.(ModuleWoker).Run(&wait_close) }(m) |
| 79 | return true |
| 80 | }) |
| 81 | |
| 82 | worker_pools_map.Range(func(k interface{}, m interface{}) bool { |
| 83 | m.(*ModuleWorkerPool).Start() |
| 84 | return true |
| 85 | }) |
| 86 | } |