mirror
/
ants
mirror of https://github.com/panjf2000/ants.git
1
0
Fork 1
Code Issues Packages Projects Releases Wiki Activity

🐶 Replace the type of variable "release" with bool type

This commit is contained in:
Andy Pan 2019-01-26 13:45:00 +08:00
parent 096e6f1513
commit c829c6f622
2 changed files with 24 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pool.go
View File

@ -48,7 +48,7 @@ type Pool struct {
workers []*Worker workers []*Worker
// release is used to notice the pool to closed itself. // release is used to notice the pool to closed itself.
release chan sig release bool
// lock for synchronous operation. // lock for synchronous operation.
lock sync.Mutex lock sync.Mutex
@ -72,7 +72,7 @@ func (p *Pool) periodicallyPurge() {
currentTime := time.Now() currentTime := time.Now()
p.lock.Lock() p.lock.Lock()
idleWorkers := p.workers idleWorkers := p.workers
if len(idleWorkers) == 0 && p.Running() == 0 && p.release != nil { if len(idleWorkers) == 0 && p.Running() == 0 && p.release {
p.lock.Unlock() p.lock.Unlock()
return return
} }
@ -122,11 +122,12 @@ func NewTimingPool(size, expiry int) (*Pool, error) {
// Submit submits a task to this pool. // Submit submits a task to this pool.
func (p *Pool) Submit(task f) error { func (p *Pool) Submit(task f) error {
if p.release != nil { if worker := p.getWorker(); worker != nil {
worker.task <- task
return nil
} else {
return ErrPoolClosed return ErrPoolClosed
} }
p.getWorker().task <- task
return nil
} }
// Running returns the number of the currently running goroutines. // Running returns the number of the currently running goroutines.
@ -159,8 +160,8 @@ func (p *Pool) ReSize(size int) {
// Release Closes this pool. // Release Closes this pool.
func (p *Pool) Release() error { func (p *Pool) Release() error {
p.once.Do(func() { p.once.Do(func() {
p.release = make(chan sig)
p.lock.Lock() p.lock.Lock()
p.release = true
idleWorkers := p.workers idleWorkers := p.workers
for i, w := range idleWorkers { for i, w := range idleWorkers {
w.task <- nil w.task <- nil
@ -191,6 +192,11 @@ func (p *Pool) getWorker() *Worker {
p.lock.Lock() p.lock.Lock()
defer p.lock.Unlock() defer p.lock.Unlock()
if p.release {
return nil
}
idleWorkers := p.workers idleWorkers := p.workers
n := len(idleWorkers) - 1 n := len(idleWorkers) - 1
if n < 0 { if n < 0 {

18
pool_func.go
View File

@ -46,7 +46,7 @@ type PoolWithFunc struct {
workers []*WorkerWithFunc workers []*WorkerWithFunc
// release is used to notice the pool to closed itself. // release is used to notice the pool to closed itself.
release chan sig release bool
// lock for synchronous operation. // lock for synchronous operation.
lock sync.Mutex lock sync.Mutex
@ -73,7 +73,7 @@ func (p *PoolWithFunc) periodicallyPurge() {
currentTime := time.Now() currentTime := time.Now()
p.lock.Lock() p.lock.Lock()
idleWorkers := p.workers idleWorkers := p.workers
if len(idleWorkers) == 0 && p.Running() == 0 && p.release != nil { if len(idleWorkers) == 0 && p.Running() == 0 && p.release {
p.lock.Unlock() p.lock.Unlock()
return return
} }
@ -124,11 +124,12 @@ func NewTimingPoolWithFunc(size, expiry int, f pf) (*PoolWithFunc, error) {
// 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 {
if p.release != nil { if worker := p.getWorker(); worker != nil {
worker.args <- args
return nil
} else {
return ErrPoolClosed return ErrPoolClosed
} }
p.getWorker().args <- args
return nil
} }
// Running returns the number of the currently running goroutines. // Running returns the number of the currently running goroutines.
@ -161,8 +162,8 @@ func (p *PoolWithFunc) ReSize(size int) {
// Release Closed this pool. // Release Closed this pool.
func (p *PoolWithFunc) Release() error { func (p *PoolWithFunc) Release() error {
p.once.Do(func() { p.once.Do(func() {
p.release = make(chan sig)
p.lock.Lock() p.lock.Lock()
p.release = true
idleWorkers := p.workers idleWorkers := p.workers
for i, w := range idleWorkers { for i, w := range idleWorkers {
w.args <- nil w.args <- nil
@ -193,6 +194,11 @@ func (p *PoolWithFunc) getWorker() *WorkerWithFunc {
p.lock.Lock() p.lock.Lock()
defer p.lock.Unlock() defer p.lock.Unlock()
if p.release {
return nil
}
idleWorkers := p.workers idleWorkers := p.workers
n := len(idleWorkers) - 1 n := len(idleWorkers) - 1
if n < 0 { if n < 0 {