Now we can safely stop waiting for tasks when shutdown is closed

2015-10-18 03:34:10 +03:00
parent d847be21c6
commit ef17093207
1 changed files with 2 additions and 6 deletions
@@ -117,12 +117,8 @@ func (s *Satan) runWorker(i int) {
 		select {
 		case t := <-s.queue:
 			s.processTask(t)
-		default:
-			select {
-			case <-s.shutdownWorkers:
-				return
-			default:
-			}
+		case <-s.shutdownWorkers:
+			return
 		}
 	}
 }