code: def _consume(self):
          
          while True:
              try:
                  task, args, kwargs = self.queue.get(True)
                  task(*args, **kwargs)
              finally:
                  self.queue.task_done()
docs: Main loop for each thread, handles picking a task off the
          queue, processing it and notifying the queue that it is done.