code: def __init__(self, name, num_workers=1, max_backlog=0):
      self.name = name
      self.max_backlog = max_backlog
      self.num_workers = num_workers
  
      self._queue = queue.Queue(maxsize=max_backlog)
  
      self._threads = []
      self._shutdown = False
      self._stopped = False
      atexit.register(self.stop_workers)
  
      for thread_num in range(self.num_workers):
          thread = threading.Thread(target=self.worker)
          thread.daemon = True
          self._threads.append(thread)
          thread.start()
  
file_path: aim/aim/ext/task_queue/queue.py
imports: import threading
  import queue
  import atexit
  import logging
label_desc: Use image node_id 1 to create a new TaskQueue object from inherited base classes: object with example: obj = TaskQueue(name, num_workers, max_backlog)