经常遇到诡异的问题，换 ubuntu 就没事了。 比如说：
import multiprocessing, time, queue
# g_queue = queue.Queue()
g_queue = multiprocessing.Queue()
c = multiprocessing.cpu_count()
def init_queue():
print("init g_queue start")
while not g_queue.empty():
g_queue.get()
for _index in range(10):
g_queue.put(_index)
print("init g_queue end")
def task_io(task_id):
print("IOTask[%s] start" % task_id)
while not g_queue.empty():
try:
data = g_queue.get(block=True, timeout=1)
print("IOTask[%s] get data: %s" % (task_id, data))
time.sleep(1)
except Exception as excep:
print("IOTask[%s] error: %s" % (task_id, str(excep)))
print("IOTask[%s] end" % task_id)
if __name__ == '__main__':
print("cpu count:", multiprocessing.cpu_count(), "\n")
print("========== 多进程执行 IO 密集型任务 ==========")
init_queue()
time_0 = time.time()
process_list = [multiprocessing.Process(target=task_io, args=(i,)) for i in range(c)]
for p in process_list:
p.start()
for p in process_list:
if p.is_alive():
p.join()
print("结束：", time.time() - time_0, "\n")
完全拿不到 queue 里面的东西，直接当空气了。
24
Select Language