【发布时间】:2016-02-27 19:40:08
【问题描述】:
谁能告诉我为什么下面的代码会出现“无法启动进程两次”的错误?据我估计,p1 和 p2 应该已经被 p.terminate() 命令强制关闭了
编辑:添加了更多代码以提供上下文 - 想提出一个简单的示例,但省略了 while 循环
import time
import os
from multiprocessing import Process
import datetime
def a():
print ("a starting")
time.sleep(30)
print ("a ending")
def b():
print ("b starting")
time.sleep(30)
print ("b ending")
morning = list(range(7,10))
lunch = list(range(11,14))
evening = list(range(17,21))
active = morning + lunch + evening
if __name__=='__main__':
p1 = Process(target = a)
p2 = Process(target = b)
while True:
while (datetime.datetime.now().time().hour) in active:
p1.start()
p2.start()
time.sleep(5)
p1.terminate()
p2.terminate()
time.sleep(5)
else:
print ("Outside hours, waiting 30 mins before retry")
time.sleep(1800)
【问题讨论】:
-
为什么有两个
p1.start()和p2.start()? -
哦,对不起!有一个 while 循环封装了它,以便在一天中的某些时间一遍又一遍地运行代码
标签: python python-3.x multiprocessing python-multiprocessing