+ def _HasRunningTaskUnlocked(self):
+ """Returns whether this worker is currently running a task.
+
+ """
+ return (self._current_task is not None)
+
+ def HasRunningTask(self):
+ """Returns whether this worker is currently running a task.
+
+ """
+ self.pool._lock.acquire()
+ try:
+ return self._HasRunningTaskUnlocked()
+ finally:
+ self.pool._lock.release()
+