From e4c0cbe843f489ef0d04d51a27d51f4327959ce3 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin <valyala@gmail.com> Date: Wed, 2 Mar 2016 16:10:38 +0200 Subject: [PATCH] code prettifying --- workerpool.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/workerpool.go b/workerpool.go index 03aee88b44..97f81bd9b8 100644 --- a/workerpool.go +++ b/workerpool.go @@ -77,12 +77,14 @@ func (wp *workerPool) Stop() { wp.lock.Unlock() } +const maxIdleWorkerDuration = 10 * time.Second + func (wp *workerPool) clean() { // Clean least recently used workers if they didn't serve connections - // for more than one second. + // for more than maxIdleWorkerDuration. wp.lock.Lock() ready := wp.ready - for len(ready) > 1 && time.Since(ready[0].t) > 10*time.Second { + for len(ready) > 1 && time.Since(ready[0].t) > maxIdleWorkerDuration { // notify the worker to stop. ready[0].ch <- nil