| | |
| | | flag.Parse() |
| | | // 日志初始化 |
| | | |
| | | insertdata.Init(*env) |
| | | structure.Init(*env) |
| | | var logFile = "./logger/" |
| | | if viper.GetString("LogBasePath") != "" { |
| | | logFile = viper.GetString("LogBasePath") |
| | |
| | | |
| | | func nRecvImpl(c deliver.Deliver, index int) { |
| | | var msg []byte |
| | | var wg1 sync.WaitGroup |
| | | p,_ := ants.NewPool(20) |
| | | syncCalculateSum := func() { |
| | | Task(msg) |
| | | wg1.Done() |
| | | } |
| | | wg1.Wait() |
| | | //var wg1 sync.WaitGroup |
| | | //p,_ := ants.NewPool(20) |
| | | //syncCalculateSum := func() { |
| | | // Task(msg) |
| | | // wg1.Done() |
| | | //} |
| | | //wg1.Wait() |
| | | var err error |
| | | for { |
| | | msg, err = c.Recv() |
| | | if err == nil { |
| | | wg1.Add(1) |
| | | _ = p.Submit(syncCalculateSum) |
| | | //go Task(msg) |
| | | //wg1.Add(1) |
| | | //_ = p.Submit(syncCalculateSum) |
| | | Task(msg) |
| | | } else { |
| | | fmt.Println(err) |
| | | logger.Info(err) |
| | | } |
| | | } |
| | | } |