diff options
author | Aliaksandr Valialkin <valyala@gmail.com> | 2016-03-31 14:41:27 +0300 |
---|---|---|
committer | Aliaksandr Valialkin <valyala@gmail.com> | 2016-03-31 14:41:27 +0300 |
commit | 9f20a62336ee632d92f75b7433a57ae901308299 (patch) | |
tree | 978c36db227c35d206433aeca0fec1ae6d9e9770 /workerpool.go | |
parent | workerpool: bugfix: do not return workerChan to ready pool on panic (diff) | |
download | fasthttp-9f20a62336ee632d92f75b7433a57ae901308299.tar.gz fasthttp-9f20a62336ee632d92f75b7433a57ae901308299.tar.bz2 fasthttp-9f20a62336ee632d92f75b7433a57ae901308299.zip |
added workerpool tests
Diffstat (limited to 'workerpool.go')
-rw-r--r-- | workerpool.go | 6 |
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() } |