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

remove some comments

This commit is contained in:
andy pan 2018-05-24 19:30:18 +08:00
parent ab6390f6d0
commit 07f98b4ac6
3 changed files with 3 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pool.go
View File

@ -126,6 +126,8 @@ func (p *Pool) getWorker() *Worker {
if n < 0 { if n < 0 {
if p.running >= p.capacity { if p.running >= p.capacity {
waiting = true waiting = true
} else {
p.running++
} }
} else { } else {
w = workers[n] w = workers[n]

2
worker.go
View File

@ -40,7 +40,7 @@ type Worker struct {
// run will start a goroutine to repeat the process // run will start a goroutine to repeat the process
// that perform the function calls. // that perform the function calls.
func (w *Worker) run() { func (w *Worker) run() {
atomic.AddInt32(&w.pool.running, 1) //atomic.AddInt32(&w.pool.running, 1)
go func() { go func() {
for f := range w.task { for f := range w.task {
if f == nil || len(w.pool.release) > 0 { if f == nil || len(w.pool.release) > 0 {

20
worker_func.go
View File

@ -53,26 +53,6 @@ func (w *WorkerWithFunc) run() {
}() }()
} }
//func (w *WorkerWithFunc) run() {
// atomic.AddInt32(&w.pool.running, 1)
// go func() {
// for {
// select {
// case args := <-w.args:
// if args == nil {
// atomic.AddInt32(&w.pool.running, -1)
// return
// }
// w.pool.poolFunc(args)
// w.pool.putWorker(w)
// case <-w.pool.release:
// atomic.AddInt32(&w.pool.running, -1)
// return
// }
// }
// }()
//}
// stop this worker. // stop this worker.
func (w *WorkerWithFunc) stop() { func (w *WorkerWithFunc) stop() {
w.args <- nil w.args <- nil