wbrawner/ansible
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Use events instead of sleep for result reading

Browse source
This commit is contained in:
James Cammarata 2017-09-30 13:27:49 -05:00
parent f860ea10c4
commit 9b6b924e9c
2 changed files with 5 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/ansible/executor/task_queue_manager.py
View file

@ -129,6 +129,7 @@ class TaskQueueManager:
self._res_queue = deque()
self._res_queue_lock = threading.Lock()
self._res_ready = threading.Event()
def _put_in_queue(self, data, queue, lock):
lock.acquire()
@ -154,6 +155,7 @@ class TaskQueueManager:
def put_result(self, data):
self._put_in_queue(data, self._res_queue, self._res_queue_lock)
self._res_ready.set()
def get_result(self):
return self._pop_off_queue(self._res_queue, self._res_queue_lock)

4
lib/ansible/plugins/strategy/__init__.py
View file

@ -506,7 +506,9 @@ class StrategyBase:
results = self._process_pending_results(iterator)
ret_results.extend(results)
if self._pending_results > 0:
time.sleep(C.DEFAULT_INTERNAL_POLL_INTERVAL)
#time.sleep(C.DEFAULT_INTERNAL_POLL_INTERVAL)
self._tqm._res_ready.wait()
self._tqm._res_ready.clear()
display.debug("no more pending results, returning what we have")