def get(self, block=True, timeout=None): ...

def get(self, timeout=None, *, _delay=10 / 1000): ...

class QueueListener(object):
    def dequeue(self, block):
        return self.queue.get(block)
    def _monitor(self):
        ...
                record = self.dequeue(True)  # instead of blocking flag it sets the timeout for interpreters.Queue
        ...

import sys
import time
import logging
from logging.handlers import QueueHandler, QueueListener
from concurrent.futures import InterpreterPoolExecutor, wait
from concurrent.interpreters import create_queue
def initworker(queue):
    loghandler = QueueHandler(queue)
    loghandler.setLevel(logging.DEBUG)
    logger = logging.getLogger()
    logger.setLevel(logging.DEBUG)
    logger.addHandler(loghandler)
def worker(num: int, delay: float):
    time.sleep(delay)  # emulate highload
    logging.debug('finish %s', str(num))
class CustomQueueListener(QueueListener):
    def dequeue(self, block: bool) -> logging.LogRecord:
        # return self.queue.get(block)  # original
        return self.queue.get()
def check(listener: QueueListener, bounds: tuple[int, int], delay: float):
    tasks = []
    with (
        InterpreterPoolExecutor(initializer=initworker, initargs=(queue, )) as pool,
        listener,
    ):
        for i in range(*bounds):
            tasks.append(pool.submit(worker, i, delay))
        wait(tasks)
if __name__ == '__main__':
    loghandler = logging.StreamHandler(sys.stdout)
    queue = create_queue()
    check(QueueListener(queue, loghandler), (0, 10), delay=0.5)  # everything is ok
    queue = create_queue()
    check(QueueListener(queue, loghandler), (10, 20), delay=1.25)  # no output, because listener thread is stopped
    queue = create_queue()
    check(CustomQueueListener(queue, loghandler), (20, 30), delay=1.25)  # everything is ok