summaryrefslogtreecommitdiff
path: root/static_pool.go
diff options
context:
space:
mode:
authorWolfy-J <[email protected]>2018-06-23 17:06:07 +0300
committerWolfy-J <[email protected]>2018-06-23 17:06:07 +0300
commit80bd89f91fd0055579717f3cc65b39176eb09000 (patch)
tree223e1980e580137b0b937cf6d8464aa59cc8733e /static_pool.go
parentddf2ce2ca7d90d6cddf7d49e973ea4ec17f8477a (diff)
realtime error handling and displaying
Diffstat (limited to 'static_pool.go')
-rw-r--r--static_pool.go5
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)