def task_done(self, future):
    """Called once task is done, releases one worker."""
self.workers.release()
Использование concurrent.futures для одновременного использования множества удаленных из очереди сообщений