diff options
Diffstat (limited to 'static_pool.go')
| -rw-r--r-- | static_pool.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/static_pool.go b/static_pool.go index ccd3f27a..cce6bd6a 100644 --- a/static_pool.go +++ b/static_pool.go @@ -28,10 +28,10 @@ type StaticPool struct { // active task executions tasks sync.WaitGroup - // workers circular allocation buffer + // workers circular allocation buf free chan *Worker - // number of workers expected to be dead in a buffer. + // number of workers expected to be dead in a buf. numDead int64 // protects state of worker list, does not affect allocation @@ -151,7 +151,6 @@ func (p *StaticPool) Destroy() { var wg sync.WaitGroup for _, w := range p.Workers() { wg.Add(1) - go w.Stop() go func(w *Worker) { defer wg.Done() p.destroyWorker(w, nil) |