我使用多处理来创建一个子进程，然后子进程将做一些耗时的长时间工作，这些工作可能永远不会结束。
我想做的是，当子进程完成一步时，它将触发父进程的事件，或者只调用一些函数。
这是我的部分脚本：
class WorkerProcess(multiprocessing.Process):
def __init__(self, port, addresslist, result_queue):
multiprocessing.Process.__init__(self)
self.exit = multiprocessing.Event()
self.serialPort = port
self.addressList = addresslist
self.sch = SerialCommunication(self.serialPort, self.addressList)
self.result_queue = result_queue
def run(self):
while not self.exit.is_set():
self.sch.RegularLoadInfo()
self.result_queue.put(self.sch.rawData)
# here trigger event or method in parent process, or let the queue put trigger it
def shutdown(self):
try:
self.sch.stopSerial()
except Exception:
print(Exception)
self.exit.set()
class DataExchange(object):
def __init__(self):
self._serialOn = False
self.workerSerial = None
def get_serialOn(self):
return self._serialOn
def set_serialOn(self, value):
self._serialOn = value
if self.serialOn == True:
result = multiprocessing.Queue()
self.workerSerial = WorkerProcess(self.serialPort, self.addressList, result)
self.workerSerial.daemon = True
self.workerSerial.start()
elif self.serialOn == False:
self.workerSerial.shutdown()
serialOn = property(get_serialOn, set_serialOn)
def OnUpdate(self, event):
# triggered by child process
# do something
pass
提前谢谢。
不能直接调用另一个进程中的方法，但有两种可能性：
a) 父级等待，直到子级发送
您需要设置一个queue，以便从子级到父级进行通信(如果需要双向通信，则需要设置pipe)，然后使父级阻塞(运行get())，直到子级发送数据(运行put())。
由于您已经在代码中设置了一个队列result，因此您要么想接受这个队列，要么将另一个队列交给WorkerProcess的__init__构造函数。
在父进程中执行以下操作：
result = multiprocessing.Queue()
self.workerSerial = WorkerProcess(self.serialPort, self.addressList, result)
self.workerSerial.daemon = True
self.workerSerial.start()
while True:
event = result.get()
if event is None:
break
if event == 'update':
self.OnUpdate()
self.workerSerial.terminate()
您需要定义孩子如何传达他发送的最后一个元素(也称为"sentinel")，我在上面的示例代码中选择了None。
一旦父级获得sentinel，它就会在子级上运行terminate()来结束它
b) 更改的父轮询
如果父母需要在等待结果的同时做一些事情，你需要定期检查你的队列中是否有东西：
# do stuff in parent
if not result.empty():
event = result.get()
# process event as above and terminate if `None`