diff --git a/lib/workerpool.py b/lib/workerpool.py index 6d533fe2d8cbca33888e9ea1c6cda439baf506cb..8db03c79aec5f76a7b8353ac3e977a444bb193ff 100644 --- a/lib/workerpool.py +++ b/lib/workerpool.py @@ -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.