Я пытаюсь создать утилиту, используя 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