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

🐯 Optimize code comments

This commit is contained in:
Andy Pan 2019-01-25 22:01:25 +08:00
parent 65b3ac9ff7
commit b6e43aeee3
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pool_func.go
View File

@ -121,7 +121,7 @@ func NewTimingPoolWithFunc(size, expiry int, f pf) (*PoolWithFunc, error) {
return p, nil return p, nil
} }
//------------------------------------------------------------------------- //---------------------------------------------------------------------------
// Serve submits a task to pool. // Serve submits a task to pool.
func (p *PoolWithFunc) Serve(args interface{}) error { func (p *PoolWithFunc) Serve(args interface{}) error {
@ -175,7 +175,7 @@ func (p *PoolWithFunc) Release() error {
return nil return nil
} }
//------------------------------------------------------------------------- //---------------------------------------------------------------------------
// incRunning increases the number of the currently running goroutines. // incRunning increases the number of the currently running goroutines.
func (p *PoolWithFunc) incRunning() { func (p *PoolWithFunc) incRunning() {
@ -233,7 +233,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 an available worker put back into queue. // Notify the invoker stuck in 'getWorker()' of there is an available worker in the worker queue.
p.cond.Signal() p.cond.Signal()
p.lock.Unlock() p.lock.Unlock()
} }