diff options
Diffstat (limited to 'static_pool.go')
| -rw-r--r-- | static_pool.go | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/static_pool.go b/static_pool.go index df20ad20..9449ea0c 100644 --- a/static_pool.go +++ b/static_pool.go @@ -239,6 +239,7 @@ func (p *StaticPool) destroyWorker(w *Worker, caused interface{}) { // watchWorker watches worker state and replaces it if worker fails. func (p *StaticPool) watchWorker(w *Worker) { err := w.Wait() + p.throw(EventWorkerDead, w) // detaching p.muw.Lock() |