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

rename methods

This commit is contained in:
Andy Pan 2018-08-03 19:28:46 +08:00
parent 39951bd2f5
commit 1444008b67
4 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pool.go
View File

@ -172,13 +172,13 @@ func (p *Pool) Release() error {
//-------------------------------------------------------------------------
// incrRunning increases the number of the currently running goroutines
func (p *Pool) incrRunning() {
// incRunning increases the number of the currently running goroutines
func (p *Pool) incRunning() {
atomic.AddInt32(&p.running, 1)
}
// decrRunning decreases the number of the currently running goroutines
func (p *Pool) decrRunning() {
// decRunning decreases the number of the currently running goroutines
func (p *Pool) decRunning() {
atomic.AddInt32(&p.running, -1)
}
@ -215,7 +215,7 @@ func (p *Pool) getWorker() *Worker {
task: make(chan f, 1),
}
w.run()
p.incrRunning()
p.incRunning()
}
return w
}

10
pool_func.go
View File

@ -177,13 +177,13 @@ func (p *PoolWithFunc) Release() error {
//-------------------------------------------------------------------------
// incrRunning increases the number of the currently running goroutines
func (p *PoolWithFunc) incrRunning() {
// incRunning increases the number of the currently running goroutines
func (p *PoolWithFunc) incRunning() {
atomic.AddInt32(&p.running, 1)
}
// decrRunning decreases the number of the currently running goroutines
func (p *PoolWithFunc) decrRunning() {
// decRunning decreases the number of the currently running goroutines
func (p *PoolWithFunc) decRunning() {
atomic.AddInt32(&p.running, -1)
}
@ -220,7 +220,7 @@ func (p *PoolWithFunc) getWorker() *WorkerWithFunc {
args: make(chan interface{}, 1),
}
w.run()
p.incrRunning()
p.incRunning()
}
return w
}

2
worker.go
View File

@ -46,7 +46,7 @@ func (w *Worker) run() {
go func() {
for f := range w.task {
if f == nil {
w.pool.decrRunning()
w.pool.decRunning()
return
}
f()

2
worker_func.go
View File

@ -46,7 +46,7 @@ func (w *WorkerWithFunc) run() {
go func() {
for args := range w.args {
if args == nil {
w.pool.decrRunning()
w.pool.decRunning()
return
}
w.pool.poolFunc(args)