diff --git a/lib/workerpool.py b/lib/workerpool.py index 25f31b4abe022a1cbf0d5ddf045671efd440da6a..16e713f0548f9b1ca93bffaad8be8b42f459c401 100644 --- a/lib/workerpool.py +++ b/lib/workerpool.py @@ -63,16 +63,6 @@ class BaseWorker(threading.Thread, object): """ 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() - def run(self): """Main thread function. @@ -81,7 +71,7 @@ class BaseWorker(threading.Thread, object): """ pool = self.pool - assert not self.HasRunningTask() + assert self._current_task is None while True: try: