code: def _spawn(self):
          
          self.queue = Queue(maxsize=self.num_threads * 10)
          for i in range(self.num_threads):
              t = Thread(target=self._consume)
              t.daemon = True
              t.start()
docs: Initialize the queue and the threads.