Глобальное состояние при многопроцессорной обработке

Question

Я обнаружил, что при импорте модулей и использовании многопроцессорности в то же время начинают возникать странные вещи. Возьмем, к примеру:

# ------------------------- 
# main.py 
# ------------------------- 
import multiprocessing 
import foo 

def bar(a): 
    foo.test() 

if __name__ == "__main__": 
    pool = multiprocessing.Pool(5) 
    pool.map(bar, [1] * 15) 

# ---------------------------- 
# foo.py 
# ---------------------------- 
import api # Note the indirect import. 

def test(): 
    print(api.a) 

# ---------------------------- 
# api.py 
# ---------------------------- 
print("Imported") 
a = 5 

Для меня этот пример выдает что-то вроде:

Imported 
Imported 
5 
5 
5 
5 
5 
5 
5 
5 
5 
5 
5 
Imported 
5 
5 
5 
5 

Обратите внимание, что модуль api импортируется (т.е. выполняется) несколько раз. Как я мог избежать этого? Я хочу запустить код внутри модуля api ровно один раз (например, статическая инициализация в C), и я хочу, чтобы результирующие состояния (в данном случае api.a) были доступны из других процессов, но только инициализировались один раз.

В реальном варианте использования я беру чувствительный ввод от пользователя в модуле api, и я хочу принять этот пользовательский ввод ровно один раз. В настоящее время пользователь должен вводить свои данные один раз за каждый процесс, выполняемый пулом - каждый раз, когда модуль импортируется.

Answer 1

Каждый процесс имеет собственный экземпляр интерпретатора, поэтому ваш модуль api импортирован несколько раз. (Новый процесс начинается каждый раз, когда Imported был напечатан).

Более подробно об этом в official documentatioin