worker.go中executeTaskWithTimeout死锁问题

[zzjha-cn]

worker.go中，executeTaskWithTimeout执行有超时限制的任务会死锁。

执行代码：

func main() {
    var errCount int32

    pool := gopool.NewGoPool(100, gopool.WithTimeout(1*time.Second), gopool.WithErrorCallback(func(err error) {
        fmt.Println("get a error")
        atomic.StoreInt32(&errCount, 1)
    }))
    defer pool.Release()

    // 超时任务
    // pool.AddTask(func() (interface{}, error) {
    //  time.Sleep(2 * time.Second)
    //  return nil, nil
    // })

    // 不超时任务
    pool.AddTask(func() (interface{}, error) {
        fmt.Println("run normal task")
        return nil, nil
    })
    pool.AddTask(func() (interface{}, error) {
        fmt.Println("run normal task")
        return nil, nil
    })
    pool.AddTask(func() (interface{}, error) {
        fmt.Println("run normal task")
        return nil, nil
    })

    pool.Wait()

    fmt.Println("err count:", errCount)
}

因为result的chan接收到值后，会在下面等待err的chan 消息，但是此时已经没有发送方了。