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
我只找到了有关使用单独脚本打开子进程的文档。有谁知道如何传递函数对象，甚至是传递函数代码的简单方法？
【问题讨论】：
标签： python function subprocess popen python-multiprocessing
我认为您正在寻找更像多处理模块的东西：
http://docs.python.org/library/multiprocessing.html#the-process-class
子进程模块用于生成进程并使用它们的输入/输出执行操作 - 不用于运行函数。
这是您的代码的multiprocessing 版本：
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
【讨论】：
processify 装饰器作为快捷方式：gist.github.com/2311116
您可以使用标准的 Unix fork 系统调用，如 os.fork()。 fork() 将创建一个新进程，运行相同的脚本。在新进程中返回0，而在旧进程中返回新进程的进程ID。
child_pid = os.fork()
if child_pid == 0:
print "New proc"
else:
print "Old proc"
对于更高级别的库，它提供多处理支持，为使用多个进程提供可移植的抽象，有multiprocessing 模块。 IBM DeveloperWorks 上有一篇文章Multiprocessing with Python，简要介绍了这两种技术。
【讨论】：
fork 不可移植；我通常会给出不可携带的答案以及它们不可携带的信息，并让提问者决定这对他们来说是否足够。正如我已经编辑了我的答案，如果你觉得我已经充分改进了它，你应该能够删除反对票；虽然如果你不这样做也没有什么不好的感觉，我只是想检查一下我做错了什么。
Brian McKenna 上面关于多处理的帖子确实很有帮助，但如果您想走线程路线（与基于进程相反），这个示例将帮助您入门：
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) 功能立即将线程置于后台。
【讨论】：