()
| 27 | } |
| 28 | |
| 29 | func (task *Task) GoPush() { |
| 30 | for i := 0; i < len(pushChannel); i++ { |
| 31 | pushChannel[i] = make(chan *PushParams, config.Conf.Task.TaskBase.PushChanSize) |
| 32 | go task.processSinglePush(pushChannel[i]) |
| 33 | } |
| 34 | } |
| 35 | |
| 36 | func (task *Task) processSinglePush(ch chan *PushParams) { |
| 37 | var arg *PushParams |