可以添加一个结束信号来告诉进程应该结束了。例如:在遍历完字典后,再向队列中放入一个特殊的结束信号。修改后的代码如下:

import multiprocessing

def item_put(q): global i for key_1, value_1 in data_1.items(): data1_list = [key_1, value_1] q.put(data1_list) i += 1 # 遍历完字典后,向队列中放入一个特殊的结束信号 q.put(None)

if name == 'main': data_1 = {'a': 1, 'b': 2, 'c': 3} i = 0 q = multiprocessing.Queue() p = multiprocessing.Process(target=item_put, args=(q,)) p.start() while True: item = q.get() if item is None: # 收到结束信号,进程结束 break print(item) p.join(

在python中使用多进程运行下面这个函数:def item_putq global i for key_1 value_1 in data_1items data1_list = key_1 value_1 qputdata1_list i += 1在上面这个函数里面data_1是一个字典我想在遍历完这个字典后结束这个进程应该怎么修改我的代码

原文地址: https://www.cveoy.top/t/topic/cspT 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录