From 5fd14ba957bd016b822b2ae9b91b84ff920dc9ec Mon Sep 17 00:00:00 2001 From: John Date: Thu, 8 Mar 2018 15:42:34 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84grpool=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- g/os/grpool/grpool_pool.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/g/os/grpool/grpool_pool.go b/g/os/grpool/grpool_pool.go index d1ab3d593..da2417773 100644 --- a/g/os/grpool/grpool_pool.go +++ b/g/os/grpool/grpool_pool.go @@ -52,11 +52,11 @@ func (p *Pool) startClearLoop() { } } } - // 如果接收到关闭通知(池已经关闭),那么不再执行清理操作,关闭所有worker后退出 + // 如果接收到关闭通知(池已经关闭),闭所有worker后退出 if len(p.stopEvents) > 0 { for { if r := p.queue.PopFront(); r != nil { - // 主动关闭所有work,防止goroutine泄露 + // 主动关闭所有worker,防止goroutine泄露 r.(*PoolWorker).stop() atomic.AddInt32(&p.number, -1) } else {