Как динамически передавать имена функций и входные данные в multiprocessing.process? - PullRequest
0 голосов
/ 06 марта 2020

Я пытаюсь создать утилиту, используя multiprocessing.process, которая должна быть импортирована в другие модули, поэтому при использовании process я могу дать другой ввод для процесса, но не уверен, как динамически передавать разные имена функций. На фоне этого, при использовании pool, некоторые из моих объектов не подлежат разборке, поэтому приступим к процессу.

def mp_handler(self, method_name, input):
    try:
        p = multiprocessing.Process(target=method_name.func_name, args=(input,))
    except Exception as e:
        logger.error("ERROR2 : " + str(traceback.format_exc()))
        raise Exception

def _read(self, filename):
    logger.info("reading the file" + filename)
    time.sleep(10)

def call(self):
    for func, i in rage(10), [self._read]:
        try:
           self._mp_handler(func, i)
        exception:
           logger.error("ERROR2 : " + str(traceback.format_exc()))
           raise Exception
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...