Что я хочу сделать: У меня есть интенсивные вычисления процессора, которые я хочу разгрузить в рабочую процесс, чтобы не блокировать мой основной сервер.
Код: Выделить всё
my_model = model_init()
def handler(args):
return my_model.process(args)
< /code>
Как использовать ProcessPoolexeCutor?concurrent.futures.ProcessPoolExecutor(max_workers=1, initializer=init_function, initargs=(model_name))
< /code>
Скажи, что я имею: < /p>
def init_function():
model = model_init()
Ядро проблемы состоит в том, как «сохранить» модель , созданная в init_function ? Позже я хочу представить задачи в ProcessPoolexeCutor и иметь возможность использовать модель , созданная в init_function для обработки задачи. Я не знаю, как пройти состояние между этими функциями. Как может функция, которая является аргументом для отправки получить доступ к переменной, которая была инициализирована, когда была вызвана инициализатор ?>
Подробнее здесь:
https://stackoverflow.com/questions/795 ... olexecutor
Мобильная версия