多进程Python启动处理时间偏移


p = Pool(2)  
p.map(start_simulation, test_devices)

就像在上面的代码中,我想用start_simulation函数启动两个工人,但是有任何方法可以通过时间间隔延迟这个吗?例如:

worker1@start_simulation  
wait 5 minutes  
worker2@start_simulation

您可能更容易实现multiprocessing.Process

import multiprocessing
import time
class Simulator(multiprocessing.Process):
    def __init__(self, test_devices):
        multiprocessing.Process.__init__(self)
        self.test_devices = test_devices
    def run(self):
        start_simulation(self.test_devices)
workers = [Simulator(test_devices), Simulator(test_devices)]
workers[0].start()
time.sleep(300)
workers[1].start()
for i in workers:
    i.join()

最新更新