Method processStrategyResultForever

controller/result.go:22–36

持续处理报警结果

()

//持续处理报警结果
func (c *Controller) processStrategyResultForever() {
	for i := 0; i < GlobalConfig.WORKER_COUNT; i++ {
		go func() {
			for {
				select {
				case result := <-c.resultPool.results:
					lg.Debug("get task result from result pool, taskid:%s", result.TaskID)
					c.processResult(result)
				default:
					time.Sleep(time.Millisecond * 100)
				}
			}
		}()
	}
}

//处理来自Inspector计算后的结果对象
func (c *Controller) processResult(strategyResult *types.StrategyResult) {