|
|
@@ -28,7 +28,7 @@ func NewChanWorker(workerId int, workerPool chan chan interface{}) *ChanWorker {
|
|
|
|
|
|
func (w *ChanWorker) Start(callback func(workerId int, msg interface{})) {
|
|
|
go func(w *ChanWorker, callback func(workerId int, msg interface{})) {
|
|
|
- defer utils.DefaultGoroutineRecover(nil, `chan池工作对象消息处理`)
|
|
|
+ //defer utils.DefaultGoroutineRecover(nil, `chan池工作对象消息处理`)
|
|
|
for {
|
|
|
// 新工作管道或每次取用工作管道后，加入工作管道池
|
|
|
w.WorkerPool <- w.JobChannel
|
marion