|
|
@ -108,7 +108,7 @@ class _WorkerThread(threading.Thread, _IdleObject): |
|
|
|
def run(self): |
|
|
|
def run(self): |
|
|
|
# call the function |
|
|
|
# call the function |
|
|
|
_log.debug('Thread d %s calling %s', self.getName(), |
|
|
|
_log.debug('Thread d %s calling %s', self.getName(), |
|
|
|
str(self._function)) |
|
|
|
str(self._function.__name__)) |
|
|
|
|
|
|
|
|
|
|
|
args = self._args |
|
|
|
args = self._args |
|
|
|
kwargs = self._kwargs |
|
|
|
kwargs = self._kwargs |
|
|
@ -150,7 +150,7 @@ class _ThreadManager(object): |
|
|
|
self._running.remove(thread_id) |
|
|
|
self._running.remove(thread_id) |
|
|
|
|
|
|
|
|
|
|
|
_log.debug('Thread id %s completed, %d threads in the queue, ' \ |
|
|
|
_log.debug('Thread id %s completed, %d threads in the queue, ' \ |
|
|
|
'%d running', thread_id, len(self._thread_pool), |
|
|
|
'%d still running', thread_id, len(self._thread_pool), |
|
|
|
len(self._running)) |
|
|
|
len(self._running)) |
|
|
|
|
|
|
|
|
|
|
|
if self._thread_pool: |
|
|
|
if self._thread_pool: |
|
|
|