forked from mirror/ants
format codes
This commit is contained in:
parent
59ad1fa56c
commit
39951bd2f5
1
pool.go
1
pool.go
|
@ -182,7 +182,6 @@ func (p *Pool) decrRunning() {
|
||||||
atomic.AddInt32(&p.running, -1)
|
atomic.AddInt32(&p.running, -1)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// getWorker returns a available worker to run the tasks.
|
// getWorker returns a available worker to run the tasks.
|
||||||
func (p *Pool) getWorker() *Worker {
|
func (p *Pool) getWorker() *Worker {
|
||||||
var w *Worker
|
var w *Worker
|
||||||
|
|
|
@ -187,7 +187,6 @@ func (p *PoolWithFunc) decrRunning() {
|
||||||
atomic.AddInt32(&p.running, -1)
|
atomic.AddInt32(&p.running, -1)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
// getWorker returns a available worker to run the tasks.
|
// getWorker returns a available worker to run the tasks.
|
||||||
func (p *PoolWithFunc) getWorker() *WorkerWithFunc {
|
func (p *PoolWithFunc) getWorker() *WorkerWithFunc {
|
||||||
var w *WorkerWithFunc
|
var w *WorkerWithFunc
|
||||||
|
|
Loading…
Reference in New Issue