Revision 7260cfbe lib/workerpool.py
| b/lib/workerpool.py | ||
|---|---|---|
| 34 | 34 |
Users of a worker pool must override RunTask in a subclass. |
| 35 | 35 |
|
| 36 | 36 |
""" |
| 37 |
# pylint: disable-msg=W0212 |
|
| 37 | 38 |
def __init__(self, pool, worker_id): |
| 38 | 39 |
"""Constructor for BaseWorker thread. |
| 39 | 40 |
|
| ... | ... | |
| 118 | 119 |
self.RunTask(*self._current_task) |
| 119 | 120 |
logging.debug("Worker %s: done with task %r",
|
| 120 | 121 |
self.worker_id, self._current_task) |
| 121 |
except: |
|
| 122 |
except: # pylint: disable-msg=W0702
|
|
| 122 | 123 |
logging.error("Worker %s: Caught unhandled exception",
|
| 123 | 124 |
self.worker_id, exc_info=True) |
| 124 | 125 |
finally: |
| ... | ... | |
| 223 | 224 |
|
| 224 | 225 |
""" |
| 225 | 226 |
for worker in self._workers + self._termworkers: |
| 226 |
if worker._HasRunningTaskUnlocked(): |
|
| 227 |
if worker._HasRunningTaskUnlocked(): # pylint: disable-msg=W0212
|
|
| 227 | 228 |
return True |
| 228 | 229 |
return False |
| 229 | 230 |
|
Also available in: Unified diff