code: def collect(self):
          
          collected = super(Command, self).collect()
          if self.faster:
              self.worker_spawn_method()
              self.post_processor()
          return collected
docs: Create some concurrent workers that process the tasks simultaneously.