Revision ef52306a
| b/lib/workerpool.py | ||
|---|---|---|
| 412 | 412 |
return True |
| 413 | 413 |
return False |
| 414 | 414 |
|
| 415 |
def HasRunningTasks(self): |
|
| 416 |
"""Checks whether there's at least one task running. |
|
| 417 |
|
|
| 418 |
""" |
|
| 419 |
self._lock.acquire() |
|
| 420 |
try: |
|
| 421 |
return self._HasRunningTasksUnlocked() |
|
| 422 |
finally: |
|
| 423 |
self._lock.release() |
|
| 424 |
|
|
| 415 | 425 |
def Quiesce(self): |
| 416 | 426 |
"""Waits until the task queue is empty. |
| 417 | 427 |
|
Also available in: Unified diff