One out of multiple thread consumers hogs queue if consumers count is > 10 about janus HOT 1 CLOSED

consumers = [loop.run_in_executor(None, consume_data, q.sync_q, x) for x in range(20)]

# in BaseEventLoop.run_in_executor:
            ...
            if executor is None:
                executor = concurrent.futures.ThreadPoolExecutor()
                self._default_executor = executor

executor = concurrent.futures.ThreadPoolExecutor()
consumers = [loop.run_in_executor(executor, consume_data, q.sync_q, x) for x in range(20)]