class TaskManager:

    def __init__(self, workers):
        self.pool = ProcessPoolExecutor(max_workers=workers)
self.workers = Semaphore(workers)

def new_task(self, function):
    pass
Использование concurrent.futures для одновременного использования множества удаленных из очереди сообщений