是否可以在子进程中运行函数而无需线程或编写单独的文件/脚本.

问题描述

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

我只找到了有关使用单独脚本打开子进程的文档.有谁知道如何传递函数对象,甚至是传递函数代码的简单方法?

I have only found documentation on opening subprocesses using separate scripts. Does anyone know how to pass function objects or even an easy way to pass function code?


解决方案

我认为您正在寻找更像多处理模块的东西:

I think you're looking for something more like the multiprocessing module:

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

子进程模块用于生成进程并使用它们的输入/输出执行操作 - 不用于运行函数.

The subprocess module is for spawning processes and doing things with their input/output - not for running functions.

这是您的代码的 multiprocessing 版本:

Here is a multiprocessing version of your code:

from multiprocessing import Process, Queue

# must be a global function    
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

相关文章