diff options
Diffstat (limited to 'static_pool.go')
| -rw-r--r-- | static_pool.go | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/static_pool.go b/static_pool.go index 5f60099a..02960825 100644 --- a/static_pool.go +++ b/static_pool.go @@ -116,13 +116,18 @@ func (p *StaticPool) Workers() (workers []*Worker) { } // Remove forces pool to remove specific worker. -func (p *StaticPool) Remove(w *Worker, err error) { +func (p *StaticPool) Remove(w *Worker, err error) bool { if w.State().Value() != StateReady && w.State().Value() != StateWorking { // unable to remove inactive worker - return + return false + } + + if _, ok := p.remove.Load(w); ok { + return false } p.remove.Store(w, err) + return true } // Exec one task with given payload and context, returns result or error. |