re
/
ants
forked from mirror/ants
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

supplement annotations

This commit is contained in:
Andy Pan 2018-12-07 01:11:54 +08:00
parent 917dfb037f
commit 4320708756
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pool.go
View File

@ -226,7 +226,7 @@ func (p *Pool) putWorker(worker *Worker) {
worker.recycleTime = time.Now() worker.recycleTime = time.Now()
p.lock.Lock() p.lock.Lock()
p.workers = append(p.workers, worker) p.workers = append(p.workers, worker)
// notify there is available worker // Notify there is an available worker put back into queue.
p.cond.Signal() p.cond.Signal()
p.lock.Unlock() p.lock.Unlock()
} }

2
pool_func.go
View File

@ -229,7 +229,7 @@ func (p *PoolWithFunc) putWorker(worker *WorkerWithFunc) {
worker.recycleTime = time.Now() worker.recycleTime = time.Now()
p.lock.Lock() p.lock.Lock()
p.workers = append(p.workers, worker) p.workers = append(p.workers, worker)
// notify there is available worker // Notify there is an available worker put back into queue.
p.cond.Signal() p.cond.Signal()
p.lock.Unlock() p.lock.Unlock()
} }