diff options
author | Wolfy-J <[email protected]> | 2018-06-23 17:06:07 +0300 |
---|---|---|
committer | Wolfy-J <[email protected]> | 2018-06-23 17:06:07 +0300 |
commit | 80bd89f91fd0055579717f3cc65b39176eb09000 (patch) | |
tree | 223e1980e580137b0b937cf6d8464aa59cc8733e /static_pool.go | |
parent | ddf2ce2ca7d90d6cddf7d49e973ea4ec17f8477a (diff) |
realtime error handling and displaying
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) |