python 进程间通信(上)
一 ?使用queue來(lái)實(shí)現(xiàn)進(jìn)程間的內(nèi)存共享
#_*_coding:utf-8_*_ from multiprocessing import Process,Queue import os,time def f(q,n):q.put([n,'hello']) if __name__ == '__main__':#此queue不是直接導(dǎo)入的import Queue,這個(gè)是multiprocessing重新封裝的q=Queue()#循環(huán)6個(gè)進(jìn)程for i in range(5):p=Process(target=f,args=(q,i))p.start()#等待子進(jìn)程完畢后在繼續(xù)執(zhí)行p.join()for i in range(q.qsize()):print q.get()顯示效果如下:
[0, 'hello', {'aa': 'bb'}]
[1, 'hello', {'aa': 'bb'}]
[2, 'hello', {'aa': 'bb'}]
[3, 'hello', {'aa': 'bb'}]
[4, 'hello', {'aa': 'bb'}]
在隊(duì)列中可以存儲(chǔ)列表,字典等類型,還是很方便的。但是python間進(jìn)程間共享內(nèi)存 ?并不是真正意義的而是需要利用第三方來(lái)實(shí)現(xiàn)queue就是
?
?
二進(jìn)程鎖LOCK
#_*_coding:utf-8_*_ from multiprocessing import Process,Lock import os,time def f(l,i):#加鎖 l.acquire()print 'hello',i#釋放鎖 l.release() if __name__ == '__main__':lock=Lock()for i in range(5):p=Process(target=f,args=(lock,i)).start()顯示效果:
hello 0
hello 1
hello 2
hello 3
hello 4
這個(gè)lock是完全復(fù)刻的線程鎖 ,沒(méi)有什么改動(dòng)。進(jìn)程間本身內(nèi)存就是獨(dú)立的,沒(méi)有什么征用資源的問(wèn)題,所以這個(gè)把鎖用處不大,但是有的時(shí)候可能需要,比如當(dāng)終端顯示的時(shí)候,多個(gè)進(jìn)程都用的同一個(gè)終端顯示。
看看父進(jìn)程和子進(jìn)程關(guān)系
?
轉(zhuǎn)載于:https://www.cnblogs.com/menkeyi/p/5810684.html
總結(jié)
以上是生活随笔為你收集整理的python 进程间通信(上)的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: Apache - Storm
- 下一篇: UGUI滚动列表ScrollView使用