code: def pause(self):
          
          for child in chain(self.consumers.values(), self.workers):
              child.pause()
  
          for child in chain(self.consumers.values(), self.workers):
              child.paused_event.wait()
docs: Pauses all the worker threads.