Est-il possible d'exécuter la fonction dans un sous-processus sans enfiler ou écrire un fichier/script séparé.

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 

Je n'ai trouvé la documentation sur l'ouverture des scripts séparés en utilisant des sous-processus. Est-ce que quelqu'un sait comment passer des objets de fonction ou même un moyen facile de passer le code de fonction?

Answer 1

Je pense que vous cherchez quelque chose de plus comme le module de multitraitement:

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

Le module subprocess est pour les processus de reproduction et de faire des choses avec leur entrée/sortie - pas pour les fonctions en cours d'exécution.

Voici une version multiprocessing de votre code:

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

Vous pouvez utiliser le standard appel système Unix fork, comme os.fork(). fork() va créer un nouveau processus, avec le même script en cours d'exécution. Dans le nouveau processus, il retournera 0, tandis que dans l'ancien processus, il retournera l'identifiant de processus du nouveau processus.

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

Pour une bibliothèque de niveau supérieur, qui fournit le support multiprocesseurs qui fournit une abstraction portable pour l'utilisation de plusieurs processus, il y a le module multiprocessing. Il y a un article sur IBM DeveloperWorks, Multiprocessing with Python, avec une brève introduction aux deux techniques. post ci-dessus de

Answer 3

Brian McKenna à propos de multitraitement est vraiment utile, mais si vous voulez aller dans la voie filetée (opposition au processus basé), cet exemple vous aider à démarrer:

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" 

Vous pouvez également utiliser la fonctionnalité setDaemon(True) pour mettre en arrière-plan le fil immédiatement.