Pauses all the worker threads.

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

        for child in chain(self.consumers.values(), self.workers):
            child.paused_event.wait()