這是主要的代碼: if __name__ == '__main__':
manager = Manager()
mylist = manager.list()
mydict = manager.dict()
mylist.append('abc')
mylist.append('xyz')
for k in mylist:
我想使用隊列來保持結果,因爲我希望消費者(串行不平行)在工作人員生成結果時處理工作人員的結果。 現在,我想知道爲什麼下面的程序掛起。 import multiprocessing as mp
import time
import numpy as np
def worker(arg):
time.sleep(0.2)
q, arr = arg
q.put(arr
比方說,我測試了下面的代碼,看看子進程池的行爲: # coding=utf-8
import os
import sys
from multiprocessing import Pool
import time
import random
def run_proc(param1):
print("child procees %s pid is %s,parent id is