diff options
Diffstat (limited to 'static_pool.go')
| -rw-r--r-- | static_pool.go | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/static_pool.go b/static_pool.go index 66b1366e..2186227b 100644 --- a/static_pool.go +++ b/static_pool.go @@ -42,7 +42,6 @@ type StaticPool struct { workers []*Worker // invalid declares set of workers to be removed from the pool. - mur sync.Mutex remove sync.Map // pool is being destroyed @@ -108,9 +107,7 @@ func (p *StaticPool) Workers() (workers []*Worker) { p.muw.RLock() defer p.muw.RUnlock() - for _, w := range p.workers { - workers = append(workers, w) - } + workers = append(workers, p.workers...) return workers } @@ -294,7 +291,12 @@ func (p *StaticPool) discardWorker(w *Worker, caused interface{}) { // destroyWorker destroys workers and removes it from the pool. func (p *StaticPool) destroyWorker(w *Worker, caused interface{}) { - go w.Stop() + go func() { + err := w.Stop() + if err != nil { + p.throw(EventWorkerError, WorkerError{Worker: w, Caused: err}) + } + }() select { case <-w.waitDone: |