3

我知道使用该subprocess模块来隔离可能出现段错误的功能。这有效:

import subprocess
# Blocking for simplicity
res = subprocess.check_output(["python", "c_library_wrapper.py", arg0, arg1, ...])

我想弄清楚的是为什么multiprocessing没有相同的效果。这似乎不起作用:

import multiprocessing
from c_library_wrapper import f
# Assume that f puts the return value into a shared queue
p = multiprocessing.Process(target=f, args=(arg0, arg1, ...))
p.start()
p.join()

这不是也创建了一个独立的流程吗?我在这里缺少一个核心概念吗?

背景:我正在隔离一个大型第三方 C 库以防止出现段错误。我知道处理段错误的最好方法是修复它们,但是这个库真的很大。

4

1 回答 1

2

您提到您正在使用共享队列。注意文档中Process.terminate的警告(通过段错误终止是类似的情况):

警告:如果在关联进程正在使用管道或队列时使用此方法,则管道或队列可能会损坏并且可能无法被其他进程使用。类似地,如果进程获得了锁或信号量等,那么终止它很可能导致其他进程死锁。

于 2014-01-23T07:43:02.307 回答