From ef52306aab58ab0bca5258f677b538c8daaf5c87 Mon Sep 17 00:00:00 2001
From: Michael Hanselmann <hansmi@google.com>
Date: Wed, 16 Nov 2011 12:35:07 +0100
Subject: [PATCH] workerpool: Export function to check for running tasks
Signed-off-by: Michael Hanselmann <hansmi@google.com>
Reviewed-by: Iustin Pop <iustin@google.com>
---
lib/workerpool.py | 10 ++++++++++
1 file changed, 10 insertions(+)
diff --git a/lib/workerpool.py b/lib/workerpool.py
index 6d533fe2d..8db03c79a 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.
--
GitLab