Handle delegate errors

Author: vardius

README.md

@@ -86,7 +86,9 @@ func main() {
 	wg.Add(jobsAmount)
 
 	for i := 0; i < jobsAmount; i++ {
-		pool.Delegate(i)
+		if err := pool.Delegate(i); err != nil {
+			panic(err)
+		}
 	}
 
 	go func() {

benchmark_test.go

@@ -7,14 +7,18 @@ import (
 
 func poolDelegate(b *testing.B, pool Pool) {
 	for n := 0; n < b.N; n++ {
-		pool.Delegate(n)
+		if err := pool.Delegate(n); err != nil {
+			b.Fatal(err)
+		}
 	}
 }
 
 func poolDelegateParallel(b *testing.B, pool Pool) {
 	b.RunParallel(func(pb *testing.PB) {
 		for pb.Next() {
-			pool.Delegate(1)
+			if err := pool.Delegate(1); err != nil {
+				b.Fatal(err)
+			}
 		}
 	})
 }

example_test.go

@@ -32,7 +32,9 @@ func Example() {
 	wg.Add(jobsAmount)
 
 	for i := 0; i < jobsAmount; i++ {
-		pool.Delegate(i)
+		if err := pool.Delegate(i); err != nil {
+			panic(err)
+		}
 	}
 
 	go func() {
@@ -74,7 +76,9 @@ func Example_second() {
 
 	go func() {
 		for n := 0; n < jobsAmount; n++ {
-			pool.Delegate(n, ch)
+			if err := pool.Delegate(n, ch); err != nil {
+				panic(err)
+			}
 		}
 	}()
 
@@ -111,7 +115,9 @@ func Example_third() {
 	// assign job
 	for i := 0; i < jobsAmount; i++ {
 		go func(i int) {
-			pool.Delegate(argx[i])
+			if err := pool.Delegate(argx[i]); err != nil {
+				panic(err)
+			}
 		}(i)
 	}
 

pool_test.go

@@ -74,7 +74,9 @@ func delegateWorkToWorkers(t *testing.T, poolSize int, jobsAmount int, workersAm
 	wg.Add(jobsAmount)
 
 	for i := 1; i <= jobsAmount; i++ {
-		pool.Delegate(i)
+		if err := pool.Delegate(i); err != nil {
+			t.Fatal(err)
+		}
 	}
 
 	go func() {