以下是问题的第一部分的解决方案-如何并行运行进程，以便每个进程都等待前一个进程完成后开始处理任务。我没有在这里讨论消息传递方面，因为它对我来说有点模糊，并且可以根据问题陈述不同地实现。在这个例子中，我们创建并运行三个worker，它们通过简单的时间延迟来模拟执行。代码段应该保存到一个可以从命令行运行的文件中。在
我们首先导入所需的模块：#!/usr/bin/env python3
import time
from multiprocessing import Process, Event
并实现一个WorkerQueue类。这个类使工人保持正确的秩序，并负责开始和结束他们。工作人员之间的通信是使用事件实现的。每个worker都有其他的\u ready和readyEvent字段，它们相应地指示前一个worker和当前worker的完成状态。注意，如果队列中只有一个worker，那么它的其他准备就绪和就绪是相同的。在
^{pr2}$
然后，我们通过继承Process类来实现工作进程本身。注意，也可以使用threading代替multiprocessing。在本例中，唯一更改的是Worker父类，Thread而不是{}。在class Worker(Process):
def __init__(self, delay, name=None):
super().__init__(name=name)
self.delay = delay
self.other_ready = Event()
self.other_ready.set()
self.ready = Event()
self.stop = Event()
def run(self):