diff options
| author |  Aliaksandr Valialkin <valyala@gmail.com>
| 2016-03-30 19:04:20 +0300 |
|---|---|---|
| committer | Aliaksandr Valialkin <valyala@gmail.com>
| 2016-03-30 19:04:20 +0300 |
| commit | 1f148c6c096a6feb516f625c0e1192301683c06d (patch) | |
| tree | a119a1492d456087590a499822bad94993fef345 /workerpool.go | |
| parent | workerpool: properly count workers (diff) | |
| download | fasthttp-1f148c6c096a6feb516f625c0e1192301683c06d.tar.gz fasthttp-1f148c6c096a6feb516f625c0e1192301683c06d.tar.bz2 fasthttp-1f148c6c096a6feb516f625c0e1192301683c06d.zip | |
workerpool: properly clean scratch buffer for workerChans
Diffstat (limited to 'workerpool.go')
| -rw-r--r-- | workerpool.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/workerpool.go b/workerpool.go index 7cdecb3..78bc30b 100644 --- a/workerpool.go +++ b/workerpool.go @@ -94,8 +94,8 @@ func (wp *workerPool) clean(scratch *[]*workerChan) { for i < n && currentTime.Sub(ready[i].lastUseTime) > maxIdleWorkerDuration { i++ } + *scratch = append((*scratch)[:0], ready[:i]...) if i > 0 { - *scratch = append((*scratch)[:0], ready[:i]...) m := copy(ready, ready[i:]) for i = m; i < n; i++ { ready[i] = nil |