Reduce spinning while waiting on queues

lib/ansible/executor/process/result.py

@@ -73,11 +73,11 @@ class ResultProcess(multiprocessing.Process):
             try:
                 if not rslt_q.empty():
                     debug("worker %d has data to read" % self._cur_worker)
-                    result = rslt_q.get()
+                    result = rslt_q.get(block=False)
                     debug("got a result from worker %d: %s" % (self._cur_worker, result))
                     break
             except queue.Empty:
-                pass
+                time.sleep(0.01)
 
             if self._cur_worker == starting_point:
                 break

lib/ansible/plugins/strategy/__init__.py

@@ -311,7 +311,7 @@ class StrategyBase:
                 else:
                     raise AnsibleError("unknown result message received: %s" % result[0])
             except Queue.Empty:
-                pass
+                time.sleep(0.01)
 
         return ret_results
 

lib/ansible/plugins/strategy/linear.py

@@ -239,9 +239,6 @@ class StrategyModule(StrategyBase):
                         self._blocked_hosts[host.get_name()] = True
                         self._queue_task(host, task, task_vars, play_context)
 
-                    results = self._process_pending_results(iterator)
-                    host_results.extend(results)
-
                     # if we're bypassing the host loop, break out now
                     if run_once:
                         break