code: def create_queue(self, register=False):
          
  
          queue = asyncio.Queue(loop=self._loop)
          if register:
              self._work_queues.add(queue)
  
          return queue
docs: Create a new work queue and optionally register it.
  
          This will make sure the queue is attached to the correct event loop.
          You can optionally choose to automatically register it so that
          wait_idle() will block until the queue is empty.
  
          Args:
              register (bool): Whether to call register_workqueue() automatically.
  
          Returns:
              asyncio.Queue: The newly created queue.