def flush(self):
        self.wake.set()
        self.wake.clear()
        self.queued_lock.acquire()
        try:
            for entry in self.queued:
                self._pool_spawn('store', self._dequeue, entry[1])
            self.queued = []
        finally:
            self.queued_lock.release()
Attempts to immediately flush all messages waiting in the queue,
dataset/ETHPy150Open slimta/python-slimta/slimta/queue/__init__.py/Queue.flush