Skip to content
Snippets Groups Projects
Commit ef52306a authored by Michael Hanselmann's avatar Michael Hanselmann
Browse files

workerpool: Export function to check for running tasks


Signed-off-by: default avatarMichael Hanselmann <hansmi@google.com>
Reviewed-by: default avatarIustin Pop <iustin@google.com>
parent e0545ee9
No related branches found
No related tags found
No related merge requests found
......@@ -412,6 +412,16 @@ class WorkerPool(object):
return True
return False
def HasRunningTasks(self):
"""Checks whether there's at least one task running.
"""
self._lock.acquire()
try:
return self._HasRunningTasksUnlocked()
finally:
self._lock.release()
def Quiesce(self):
"""Waits until the task queue is empty.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment