workerpool: bugfix: do not return workerChan to ready pool on panic

This commit is contained in:
Aliaksandr Valialkin
2016-03-31 12:37:46 +03:00
parent e64702d6f0
commit 4fa2d5db39
+3 -4
View File
@@ -194,12 +194,11 @@ func (wp *workerPool) workerFunc(ch *workerChan) {
defer func() {
if r := recover(); r != nil {
wp.Logger.Printf("panic: %s\nStack trace:\n%s", r, debug.Stack())
if c != nil {
c.Close()
}
}
if c != nil {
c.Close()
wp.release(ch)
}
wp.lock.Lock()
wp.workersCount--
wp.lock.Unlock()