code: def run(self):
          '''Define the job of each process to run.
          '''
          if self.verbose:
              pbar = tqdm(total=100)
          while True:
              task_remain = self._task_queue.qsize()
              task_finished = int((float(self.total_task - task_remain) /
                                   float(self.total_task)) * 100)
              if task_finished % 20 == 0 and task_finished != self.current_state:
                  self.current_state = task_finished
                  logger.info('{0}% done'.format(task_finished))
                  if self.verbose and task_finished > 0:
                      pbar.update(20)
              if task_remain == 0:
                  break
          logger.debug('All task data cleared'f run(self):
          '''Define the job of each process to run.
          '''
          if self.verbose:
              pbar = tqdm(total=100)
          while True:
              task_remain = self._task_queue.qsize()
              task_finished = int((float(self.total_task - task_remain) /
                                   float(self.total_task)) * 100)
              if task_finished % 20 == 0 and task_finished != self.current_state:
                  self.current_state = task_finished
                  logger.info('{0}% done'.format(task_finished))
                  if self.verbose and task_finished > 0:
                      pbar.update(20)
              if task_remain == 0:
                  break
          logger.debug('All task data cleared')
docs: Define the job of each process to run.