update readme files

This commit is contained in:
Andy Pan 2018-12-01 19:41:02 +08:00
parent a0d7a0e68f
commit 93b755c5ad
2 changed files with 4 additions and 8 deletions

View File

@ -74,10 +74,9 @@ func main() {
var wg sync.WaitGroup var wg sync.WaitGroup
for i := 0; i < runTimes; i++ { for i := 0; i < runTimes; i++ {
wg.Add(1) wg.Add(1)
ants.Submit(func() error { ants.Submit(func() {
demoFunc() demoFunc()
wg.Done() wg.Done()
return nil
}) })
} }
wg.Wait() wg.Wait()
@ -86,10 +85,9 @@ func main() {
// use the pool with a function // use the pool with a function
// set 10 the size of goroutine pool and 1 second for expired duration // set 10 the size of goroutine pool and 1 second for expired duration
p, _ := ants.NewPoolWithFunc(10, func(i interface{}) error { p, _ := ants.NewPoolWithFunc(10, func(i interface{}) {
myFunc(i) myFunc(i)
wg.Done() wg.Done()
return nil
}) })
defer p.Release() defer p.Release()
// submit tasks // submit tasks

View File

@ -73,10 +73,9 @@ func main() {
var wg sync.WaitGroup var wg sync.WaitGroup
for i := 0; i < runTimes; i++ { for i := 0; i < runTimes; i++ {
wg.Add(1) wg.Add(1)
ants.Submit(func() error { ants.Submit(func() {
demoFunc() demoFunc()
wg.Done() wg.Done()
return nil
}) })
} }
wg.Wait() wg.Wait()
@ -85,10 +84,9 @@ func main() {
// use the pool with a function // use the pool with a function
// set 10 the size of goroutine pool and 1 second for expired duration // set 10 the size of goroutine pool and 1 second for expired duration
p, _ := ants.NewPoolWithFunc(10, func(i interface{}) error { p, _ := ants.NewPoolWithFunc(10, func(i interface{}) {
myFunc(i) myFunc(i)
wg.Done() wg.Done()
return nil
}) })
defer p.Release() defer p.Release()
// submit tasks // submit tasks