Возможно ли запустить функцию в подпроцессе без потоковой передачи или записи отдельного файла/скрипта.

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 

Я только нашел документацию по открытию подпроцессов с использованием отдельных скриптов. Кто-нибудь знает, как передать объекты функции или даже простой способ передать код функции?

Answer 1

Я думаю, что вы ищете что-то вроде модуля многопроцессорной:

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

Модуль подпроцесса для порождения процессов и делать вещи с их ввода/вывода - не для выполнения функций.

Вот multiprocessing версия кода:

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

Вы можете использовать стандартный Unix fork системный вызов, так как os.fork(). fork() создаст новый процесс с тем же скриптом. В новом процессе он вернет 0, а в старом процессе он вернет идентификатор процесса нового процесса.

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

Для более высокого уровня библиотеки, которая обеспечивает поддержку мультипроцессорной, которая обеспечивает переносимые абстракции для использования нескольких процессов, есть multiprocessing модуля. В статье по IBM DeveloperWorks, Multiprocessing with Python есть краткое введение в оба метода. выше пост

Answer 3

Брайана МакКенны о многопроцессорной действительно полезно, но если вы хотите идти вниз нарезной маршрут (в отличие от перерабатывают на основе), этот пример, чтобы вы начали:

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" 

Вы также можете использовать функция setDaemon(True) предназначена для мгновенного выделения потока.