Completando un poco la respuesta de Trauma.
Existen distintas formas de implementar el nuevo proceso y depende del sistema operativo de turno básicamente, las dos formas principales y más conocidas (a muy a grandes rasgos) son:
fork
: en este caso se crea una copia del proceso padre, el proceso secundario ya está en posesión de exactamente los mismos recursos que el principal, cada estructura de datos, archivo abierto, conexión, etc que existía en el proceso principal todavía está ahí y se puede usar en el secundario inmediatamente. A partir de aquí se produce una bifurcación (de ahí lo de "fork") y cada proceso continua su trabajo por su lado. La creación de procesos es mucho más rápida y más liviana en recursos.
spawn
: en este caso se crea un nuevo proceso desde cero, con su propio intérprete Python y carga todos los módulos nuevamente.
El método fork
es propio de sistemas POSIX y no va a estar disponible en algunos casos por tanto, como ocurre en Windows, que carece de la posibilidad de llamar a fork()
.
En el caso de usar spawn
, se lanza un nuevo intérprete y ejecuta el módulo de nuevo (importa todo de nuevo, instancia objetos globales desde cero, etc), es casi como si ejecutaramos el módulo en una nueva terminal, digo "casi" porque lógicamente hay algunas instrucciones especiales. El proceso hijo no ejecuta la sección if __name__ == '__main__'
, que es dónde defines tu variable, sencillamente porque el intérprete del proceso hijo no ejecuta el módulo como "modulo principal". Al no ejecutar el condicional, no va a existir la variable cuando la función es llamada.
De hecho, el condicional if __name__ == '__main__'
se usa para proteger el punto de entrada y evitar que se ejecuten cosas que no deberían en el proceso hijo, lo más obvio que no se vuelva a llamar a Process
desde el proceso hijo. El uso de este condicional, aunque siempre es buena idea, es especialmente relevante en Windows o cuando forzamos el uso de spawn
.
De esto se deduce que si declaras la variable en el espacio global, pero fuera del condicional, no tendrás el problema comentado:
#!/usr/bin/python3.5
import multiprocessing as mp
mi_variable = "hola"
def funcion1():
print(mi_variable)
def funcionProceso():
try:
evaluacion = mp.Process(target=funcion1)
evaluacion.start()
evaluacion.join()
except Exception as e:
e = str(e)
print(e)
if __name__ == '__main__':
funcion1()
funcionProceso()
En los sistemas POSIX la creación de procesos pueden utilizar la bifurcación como hemos dicho y todo el estado global del padre se mantiene intacto de inicio. En este caso la variable si que existe porque fue creada por el proceso padre, que si ejecutaste como módulo principal, y luego "copiada" por el hijo para preparar la bifurcación, por lo que no muestra el error que describes.
Las consecuencias y bondades de un sistema u otro a la hora de levantar un nuevo proceso van más lejos y es una larga discusión.
Si alguien quiere reproducir el error en POSIX basta con cambiar el modo de creación del proceso, que es fork
por defecto, para que use spawn
:
import multiprocessing as mp
def funcion1():
print(mi_variable)
def funcionProceso():
try:
evaluacion = mp.Process(target=funcion1)
evaluacion.start()
evaluacion.join()
except Exception as e:
e = str(e)
print(e)
if __name__ == '__main__':
mp.set_start_method('spawn')
mi_variable = 'Hola'
funcion1()
funcionProceso()
De cualquier forma, cuidado con las variables globales, si además las unes a multiproceso/multihilo... Ten en cuenta que la variable en todo caso se "copia", no se comparte jamás entre procesos, si el proceso hijo la modifica el padre no se va a enterar y viceversa sin importar que se use fork
o spawn
. Como comenta Trauma en su respuesta en ningún caso puedes presuponer que la variable tenga el mismo valor en ambos procesos ni siquiera de inicio, por ejemplo suponiendo que se usa spawn
y tu variable se define mediante mi_variable = random.randint(1, 100)
lo más seguro es que en cada proceso tenga un valor distinto. Es generalmente más apropiado pasar las variables como argumento, siempre que el objeto sea "picklable", pero serán variables distintas de todas formas:
#!/usr/bin/python3.5
import multiprocessing as mp
def funcion(lista_compartida):
lista_compartida.append(3)
print("Desde proceso hijo:", lista_compartida)
if __name__ == '__main__':
lista_compartida = [1, 2]
evaluacion = mp.Process(target=funcion, args=(lista_compartida, ))
evaluacion.start()
evaluacion.join()
print("Desde proceso padre:", lista_compartida)
Desde proceso hijo: [1, 2, 3]
Desde proceso padre: [1, 2]
Si necesitas compartir realmente la variable debes usar métodos adecuados y seguros para ello como son las colas, memoria compartida (multiprocesing.Value
, multiprocesing.Array
), Manager
, etc
#!/usr/bin/python3.5
import multiprocessing as mp
def funcion(lista_compartida):
lista_compartida.append(3)
print("Desde proceso hijo:", lista_compartida)
if __name__ == '__main__':
manager = mp.Manager()
lista_compartida = manager.list([1, 2])
evaluacion = mp.Process(target=funcion, args=(lista_compartida, ))
evaluacion.start()
evaluacion.join()
print("Desde proceso padre:", lista_compartida)
Desde proceso hijo: [1, 2, 3]
Desde proceso padre: [1, 2, 3]