Revision ccedb11b lib/workerpool.py
| b/lib/workerpool.py | ||
|---|---|---|
| 63 | 63 |
""" |
| 64 | 64 |
return (self._current_task is not None) |
| 65 | 65 |
|
| 66 |
def HasRunningTask(self): |
|
| 67 |
"""Returns whether this worker is currently running a task. |
|
| 68 |
|
|
| 69 |
""" |
|
| 70 |
self.pool._lock.acquire() |
|
| 71 |
try: |
|
| 72 |
return self._HasRunningTaskUnlocked() |
|
| 73 |
finally: |
|
| 74 |
self.pool._lock.release() |
|
| 75 |
|
|
| 76 | 66 |
def run(self): |
| 77 | 67 |
"""Main thread function. |
| 78 | 68 |
|
| ... | ... | |
| 81 | 71 |
""" |
| 82 | 72 |
pool = self.pool |
| 83 | 73 |
|
| 84 |
assert not self.HasRunningTask()
|
|
| 74 |
assert self._current_task is None
|
|
| 85 | 75 |
|
| 86 | 76 |
while True: |
| 87 | 77 |
try: |
Also available in: Unified diff