En cours de développement

workers/pool.go

@@ -79,7 +79,7 @@ func (p *pool) workerStopped(wID string, end bool) int {
 		}
 	}
 
-	return len(p.workers)
+	return p.size()
 }
 
 func (p *pool) stop() {

workers/supervisor.go

@@ -46,6 +46,10 @@ func (s *supervisor) loop() {
 
 		switch e {
 		case "stop":
+			if s.pool.size() == 0 {
+				return
+			}
+
 			if !end {
 				end = true
 				s.pool.stop()