Fix workers when channel gets closed

Author: vardius

pool.go

@@ -46,8 +46,10 @@ func (p *pool) Start(maxWorkers int, fn interface{}) error {
 		go func() {
 			for {
 				select {
-				case args := <-p.queue:
-					h.Call(args)
+				case args, ok := <-p.queue:
+					if ok {
+						h.Call(args)
+					}
 				case <-p.ctx.Done():
 					return
 				}

pool_test.go

@@ -67,7 +67,7 @@ func delegateWorkToWorkers(t *testing.T, poolSize int, jobsAmount int, workersAm
 	}
 
 	if sum == 0 {
-		fmt.Errorf("Delegating job %d to %d workers faild", jobsAmount, workersAmount)
+		fmt.Errorf("Delegating job %d to %d workers failed", jobsAmount, workersAmount)
 		t.Fail()
 	}
 }