|
|
@ -147,12 +147,12 @@ class _ThreadManager(object): |
|
|
|
# not actually a widget. It's the object that emitted the signal, in |
|
|
|
# not actually a widget. It's the object that emitted the signal, in |
|
|
|
# this case, the _WorkerThread object. |
|
|
|
# this case, the _WorkerThread object. |
|
|
|
thread_id = widget.getName() |
|
|
|
thread_id = widget.getName() |
|
|
|
|
|
|
|
|
|
|
|
_log.debug('Thread id %s completed, %d threads in the queue', |
|
|
|
|
|
|
|
thread_id, len(self._thread_pool)) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
self._running.remove(thread_id) |
|
|
|
self._running.remove(thread_id) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
_log.debug('Thread id %s completed, %d threads in the queue, ' \ |
|
|
|
|
|
|
|
'%d running', thread_id, len(self._thread_pool), |
|
|
|
|
|
|
|
len(self._running)) |
|
|
|
|
|
|
|
|
|
|
|
if self._thread_pool: |
|
|
|
if self._thread_pool: |
|
|
|
if len(self._running) < self._max_threads: |
|
|
|
if len(self._running) < self._max_threads: |
|
|
|
next = self._thread_pool.pop() |
|
|
|
next = self._thread_pool.pop() |
|
|
|