aboutsummaryrefslogtreecommitdiff
path: root/workerpool.go
diff options
context:
space:
mode:
authorGravatar Aliaksandr Valialkin <valyala@gmail.com> 2016-03-31 14:41:27 +0300
committerGravatar Aliaksandr Valialkin <valyala@gmail.com> 2016-03-31 14:41:27 +0300
commit9f20a62336ee632d92f75b7433a57ae901308299 (patch)
tree978c36db227c35d206433aeca0fec1ae6d9e9770 /workerpool.go
parentworkerpool: bugfix: do not return workerChan to ready pool on panic (diff)
downloadfasthttp-9f20a62336ee632d92f75b7433a57ae901308299.tar.gz
fasthttp-9f20a62336ee632d92f75b7433a57ae901308299.tar.bz2
fasthttp-9f20a62336ee632d92f75b7433a57ae901308299.zip
added workerpool tests
Diffstat (limited to 'workerpool.go')
-rw-r--r--workerpool.go6
1 files changed, 4 insertions, 2 deletions
diff --git a/workerpool.go b/workerpool.go
index 42ea62e..222adbe 100644
--- a/workerpool.go
+++ b/workerpool.go
@@ -72,10 +72,12 @@ func (wp *workerPool) Stop() {
// Do not wait for busy workers - they will stop after
// serving the connection and noticing wp.mustStop = true.
wp.lock.Lock()
- for _, ch := range wp.ready {
+ ready := wp.ready
+ for i, ch := range ready {
ch.ch <- nil
+ ready[i] = nil
}
- wp.ready = nil
+ wp.ready = ready[:0]
wp.mustStop = true
wp.lock.Unlock()
}