diff --git a/README.md b/README.md index b609cca..82df2ad 100644 --- a/README.md +++ b/README.md @@ -74,10 +74,9 @@ func main() { var wg sync.WaitGroup for i := 0; i < runTimes; i++ { wg.Add(1) - ants.Submit(func() error { + ants.Submit(func() { demoFunc() wg.Done() - return nil }) } wg.Wait() @@ -86,10 +85,9 @@ func main() { // use the pool with a function // 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) wg.Done() - return nil }) defer p.Release() // submit tasks diff --git a/README_ZH.md b/README_ZH.md index 1ba7098..3995bca 100644 --- a/README_ZH.md +++ b/README_ZH.md @@ -73,10 +73,9 @@ func main() { var wg sync.WaitGroup for i := 0; i < runTimes; i++ { wg.Add(1) - ants.Submit(func() error { + ants.Submit(func() { demoFunc() wg.Done() - return nil }) } wg.Wait() @@ -85,10 +84,9 @@ func main() { // use the pool with a function // 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) wg.Done() - return nil }) defer p.Release() // submit tasks