(wait *sync.WaitGroup)
| 146 | } |
| 147 | |
| 148 | func (this *module) recover(wait *sync.WaitGroup) { |
| 149 | if r := recover(); r != nil { |
| 150 | slog.LogError("module_recovery", "recover error :%v", r) |
| 151 | slog.LogError("module_recovery", "%s", string(debug.Stack())) |
| 152 | go this.Run(wait) // continue to run |
| 153 | } |
| 154 | } |
| 155 | |
| 156 | func (this *module) Run(wait *sync.WaitGroup) { |
| 157 | runtime.LockOSThread() |