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()