diff --git a/README.md b/README.md index c078046..6228cbf 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 e06c36e..edaddb6 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 diff --git a/ants_benchmark_test.go b/ants_benchmark_test.go index daef33c..2b1f327 100644 --- a/ants_benchmark_test.go +++ b/ants_benchmark_test.go @@ -36,13 +36,12 @@ const ( benchAntsSize = 200000 ) -func demoFunc() error { +func demoFunc() { n := 10 time.Sleep(time.Duration(n) * time.Millisecond) - return nil } -func demoPoolFunc(args interface{}) error { +func demoPoolFunc(args interface{}) { //m := args.(int) //var n int //for i := 0; i < m; i++ { @@ -51,7 +50,6 @@ func demoPoolFunc(args interface{}) error { //return nil n := args.(int) time.Sleep(time.Duration(n) * time.Millisecond) - return nil } func BenchmarkGoroutineWithFunc(b *testing.B) { @@ -88,10 +86,9 @@ func BenchmarkSemaphoreWithFunc(b *testing.B) { func BenchmarkAntsPoolWithFunc(b *testing.B) { var wg sync.WaitGroup - p, _ := ants.NewPoolWithFunc(benchAntsSize, func(i interface{}) error { + p, _ := ants.NewPoolWithFunc(benchAntsSize, func(i interface{}) { demoPoolFunc(i) wg.Done() - return nil }) defer p.Release() diff --git a/ants_test.go b/ants_test.go index 2ced83d..957bbce 100644 --- a/ants_test.go +++ b/ants_test.go @@ -54,10 +54,9 @@ var curMem uint64 func TestAntsPoolWithFunc(t *testing.T) { var wg sync.WaitGroup - p, _ := ants.NewPoolWithFunc(AntsSize, func(i interface{}) error { + p, _ := ants.NewPoolWithFunc(AntsSize, func(i interface{}) { demoPoolFunc(i) wg.Done() - return nil }) defer p.Release() @@ -94,10 +93,9 @@ func TestAntsPool(t *testing.T) { var wg sync.WaitGroup for i := 0; i < n; i++ { wg.Add(1) - ants.Submit(func() error { + ants.Submit(func(){ demoFunc() wg.Done() - return nil }) } wg.Wait() diff --git a/examples/main.go b/examples/main.go index feef5c4..521172c 100644 --- a/examples/main.go +++ b/examples/main.go @@ -55,10 +55,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() @@ -67,10 +66,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/pool.go b/pool.go index 52a16f1..c7e9aa7 100644 --- a/pool.go +++ b/pool.go @@ -30,7 +30,7 @@ import ( type sig struct{} -type f func() error +type f func() // Pool accept the tasks from client,it limits the total // of goroutines to a given number by recycling goroutines. diff --git a/pool_func.go b/pool_func.go index aff43cb..4ccbb0f 100644 --- a/pool_func.go +++ b/pool_func.go @@ -28,7 +28,7 @@ import ( "time" ) -type pf func(interface{}) error +type pf func(interface{}) // PoolWithFunc accept the tasks from client,it limits the total // of goroutines to a given number by recycling goroutines.