python - lock - ¿Es posible ejecutar la función en un subproceso sin enhebrar o escribir un archivo/script por separado?

python pool thread

Question

import subprocess
def my_function(x):
return x + 100
output = subprocess.Popen(my_function, 1) #I would like to pass the function object and its arguments
print output
#desired output: 101

Solo he encontrado documentación sobre la apertura de subprocesos usando scripts separados. ¿Alguien sabe cómo pasar objetos de función o incluso una manera fácil de pasar el código de función?

Answer 1

Creo que estás buscando algo más como el módulo de multiprocesamiento:

http://docs.python.org/library/multiprocessing.html#the-process-class

El módulo de subproceso es para procesos de desove y hacer cosas con su entrada / salida, no para funciones en ejecución.

Aquí hay una versión de multiprocessing de su código:

from multiprocessing import Process, Queue
def my_function(q, x):
q.put(x + 100)
if __name__ == ''__main__'':
queue = Queue()
p = Process(target=my_function, args=(queue, 1))
p.start()
p.join() # this blocks until the process terminates
result = queue.get()
print result

Answer 2

La publicación anterior de Brian McKenna sobre el multiprocesamiento es realmente útil, pero si desea ir por la ruta enhebrada (en oposición a la basada en procesos), este ejemplo lo ayudará a comenzar:

import threading
import time
def blocker():
while True:
print "Oh, sorry, am I in the way?"
time.sleep(1)
t = threading.Thread(name=''child procs'', target=blocker)
t.start()
# Prove that we passed through the blocking call
print "No, that''s okay"

También puede usar la función setDaemon(True) para hacer un fondo del hilo inmediatamente.

Answer 3

Puede usar la llamada estándar del sistema de fork Unix, como os.fork() . fork() creará un nuevo proceso, con la misma secuencia de comandos ejecutándose. En el nuevo proceso, devolverá 0, mientras que en el proceso anterior devolverá la identificación del proceso del nuevo proceso.

child_pid = os.fork()
if child_pid == 0:
print "New proc"
else:
print "Old proc"

Para una biblioteca de nivel superior, que proporciona soporte de multiprocesamiento que proporciona una abstracción portátil para usar procesos múltiples, existe el módulo de multiprocessing . Hay un artículo sobre IBM Developer Works , multiprocesamiento con Python , con una breve introducción a ambas técnicas.