diff options
| author | Wolfy-J <[email protected]> | 2018-06-13 20:22:06 +0300 |
|---|---|---|
| committer | Wolfy-J <[email protected]> | 2018-06-13 20:22:06 +0300 |
| commit | 87fff670cc5a446f4c396c30d330ce7958e9f40f (patch) | |
| tree | 4a6b39b015a4ca8a49b0a3cd4874a3a2d0f9446f /static_pool.go | |
| parent | 1073eae0a28c6c4603763e79437891e6acdcc988 (diff) | |
additional event
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() |