进程间通讯

cooolr 于 2023-01-30 发布
>>>from multiprocessing import Process,Queue
>>>from threading import Thread
>>>def testmulti(i,q):
>>>    try:
>>>        q.put('ok')
>>>    except:
>>>        q.put('error')
>>>
>>>q=Queue()
>>>t=range(5)
>>>for i in range(5):
 >>>   t[i]=Thread(target=testmulti,args=(i,q))
>>>
>>>if __name__=='__main__':
>>>    
>>>   for i in t:
>>>        i.start()
>>>    for i in t:
>>>        i.join()
>>>    a=[]
>>>    for i in t:
>>>       a.append(q.get())
>>>    print a
>>>    if a.count('ok') == len(t):
>>>        print a.count('error')