code: def terminate_all(self):
          
          for worker in self._workers:
              worker.terminate()
  
          # for thread in self._threads:
          #     try:
          #         thread.terminate()
          #         thread.wait()
          #     except Exception:
          #         pass
          self._queue_workers = deque()
docs: Terminate all worker processes.