From 46519d2a383c9564007e1d2a6beb492988f8c6c9 Mon Sep 17 00:00:00 2001 From: Wolfy-J Date: Fri, 3 May 2019 13:28:49 +0300 Subject: empty static pool --- static_pool.go | 8 -------- 1 file changed, 8 deletions(-) (limited to 'static_pool.go') diff --git a/static_pool.go b/static_pool.go index d81ef7e2..1409fc3f 100644 --- a/static_pool.go +++ b/static_pool.go @@ -122,14 +122,6 @@ func (p *StaticPool) Remove(w *Worker, err error) { } p.remove.Store(w, err) - - // cleanup workers which were scheduled for deletion after stop has been started - p.remove.Range(func(key, value interface{}) bool { - if key.(*Worker).State().Value() == StateStopped || key.(*Worker).State().Value() == StateErrored { - p.remove.Delete(key) - } - return true - }) } // Exec one task with given payload and context, returns result or error. -- cgit v1.2.3