Common - MutexQueues:

#           self.mutex_queues.signal_done(device_uuid)

#           self.mutex_queues.signal_done(device_uuid)

import threading

import threading

from queue import Queue

from queue import Queue, Empty

from typing import Dict

from typing import Dict

class MutexQueues:

class MutexQueues:

        with self.lock:

        with self.lock:

            queue : Queue = self.mutex_queues.setdefault(queue_name, Queue())

            queue : Queue = self.mutex_queues.setdefault(queue_name, Queue())

            # remove muself from the queue

            # remove myself from the queue

            queue.get_nowait()

            try:

                queue.get(block=True, timeout=0.1)

            except Empty:

                pass

            # if there are no other tasks queued, return

            # if there are no other tasks queued, return

            if queue.qsize() == 0: return

            if queue.qsize() == 0: return