diff --git a/pool.go b/pool.go index ad78fe0..03f88c0 100644 --- a/pool.go +++ b/pool.go @@ -129,16 +129,6 @@ func (p *Pool) Running() int { return int(atomic.LoadInt32(&p.running)) } -// incrRunning increases the number of the currently running goroutines -func (p *Pool) incrRunning() { - atomic.AddInt32(&p.running, 1) -} - -// decrRunning decreases the number of the currently running goroutines -func (p *Pool) decrRunning() { - atomic.AddInt32(&p.running, -1) -} - // Free returns the available goroutines to work func (p *Pool) Free() int { return int(atomic.LoadInt32(&p.capacity) - atomic.LoadInt32(&p.running)) @@ -182,6 +172,17 @@ func (p *Pool) Release() error { //------------------------------------------------------------------------- +// incrRunning increases the number of the currently running goroutines +func (p *Pool) incrRunning() { + atomic.AddInt32(&p.running, 1) +} + +// decrRunning decreases the number of the currently running goroutines +func (p *Pool) decrRunning() { + atomic.AddInt32(&p.running, -1) +} + + // getWorker returns a available worker to run the tasks. func (p *Pool) getWorker() *Worker { var w *Worker diff --git a/pool_func.go b/pool_func.go index c672bd2..4b59bc1 100644 --- a/pool_func.go +++ b/pool_func.go @@ -134,16 +134,6 @@ func (p *PoolWithFunc) Running() int { return int(atomic.LoadInt32(&p.running)) } -// incrRunning increases the number of the currently running goroutines -func (p *PoolWithFunc) incrRunning() { - atomic.AddInt32(&p.running, 1) -} - -// decrRunning decreases the number of the currently running goroutines -func (p *PoolWithFunc) decrRunning() { - atomic.AddInt32(&p.running, -1) -} - // Free returns the available goroutines to work func (p *PoolWithFunc) Free() int { return int(atomic.LoadInt32(&p.capacity) - atomic.LoadInt32(&p.running)) @@ -187,6 +177,17 @@ func (p *PoolWithFunc) Release() error { //------------------------------------------------------------------------- +// incrRunning increases the number of the currently running goroutines +func (p *PoolWithFunc) incrRunning() { + atomic.AddInt32(&p.running, 1) +} + +// decrRunning decreases the number of the currently running goroutines +func (p *PoolWithFunc) decrRunning() { + atomic.AddInt32(&p.running, -1) +} + + // getWorker returns a available worker to run the tasks. func (p *PoolWithFunc) getWorker() *WorkerWithFunc { var w *WorkerWithFunc