import multiprocessing
def printt(q):
if q.empty():
pass
else:
data = q.get()
print data
if __name__ == "__main__":
q = multiprocessing.JoinableQueue()
for i in range(5):
q.put()
while 1:
for i in range(3):
process = multiprocessing.Process(target=printt, arg=(q,))
process.start()
process.join()
q.join()
代码如上所示。我的问题是如何控制冗余进程,因为当我把可分为整数的项目编号放入时,上面的代码将产生错误。我如何在不产生错误的同时完成打印编号的任务
修复此问题的代码:
相关问题 更多 >
编程相关推荐