Python進(jìn)程間通信multiprocess代碼實(shí)例
仔細(xì)說(shuō)來(lái),multiprocess不是一個(gè)模塊而是python中一個(gè)操作、管理進(jìn)程的包。 之所以叫multi是取自multiple的多功能的意思,在這個(gè)包中幾乎包含了和進(jìn)程有關(guān)的所有子模塊。由于提供的子模塊非常多,為了方便大家歸類記憶,我將這部分大致分為四個(gè)部分:創(chuàng)建進(jìn)程部分,進(jìn)程同步部分,進(jìn)程池部分,進(jìn)程之間數(shù)據(jù)共享。重點(diǎn)強(qiáng)調(diào):進(jìn)程沒(méi)有任何共享狀態(tài),進(jìn)程修改的數(shù)據(jù),改動(dòng)僅限于該進(jìn)程內(nèi),但是通過(guò)一些特殊的方法,可以實(shí)現(xiàn)進(jìn)程之間數(shù)據(jù)的共享。
有了之前多線程使用以及線程間queue的基礎(chǔ),多進(jìn)程以及進(jìn)程間通信就很好理解了,下面是多進(jìn)程基本語(yǔ)法以及進(jìn)程間通信簡(jiǎn)單示例
#多進(jìn)程基本語(yǔ)法import multiprocessing, time, osdef process_test(): time.sleep(3) print('my multiprocessing test') print('my pprocess id is',os.getppid()) print('my process id is',os.getpid())if __name__ == ’__main__’: #多線程必須寫在if __name__后面,為什么??? process = multiprocessing.Process(target=process_test) #啟動(dòng)子進(jìn)程 process.start()#多進(jìn)程間數(shù)據(jù)通信,多進(jìn)程的queue實(shí)際上是python將一個(gè)queue序列化后再反序列化給其它進(jìn)程#定義一個(gè)函數(shù),第一個(gè)形參傳遞一個(gè)進(jìn)程queuedef m_queue_test(Queue, name): Queue.put(('multiprocess queue test',name)) #put一次只能傳遞一個(gè)數(shù)據(jù)對(duì)象,多個(gè)對(duì)象必須使用列表 元組 字典等傳遞if __name__ == ’__main__’: q = multiprocessing.Queue() #主進(jìn)程實(shí)例化一個(gè)進(jìn)程queue process2 = multiprocessing.Process(target=m_queue_test, args=(q, 'zsq')) #將q傳遞給子進(jìn)程,由子進(jìn)程往里面?zhèn)鬟f數(shù)據(jù) process2.start() print(q.get())#主進(jìn)程從queue里面讀數(shù)據(jù)
以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持好吧啦網(wǎng)。
相關(guān)文章:
1. vue實(shí)現(xiàn)web在線聊天功能2. JavaEE SpringMyBatis是什么? 它和Hibernate的區(qū)別及如何配置MyBatis3. JavaScript實(shí)現(xiàn)頁(yè)面動(dòng)態(tài)驗(yàn)證碼的實(shí)現(xiàn)示例4. Springboot 全局日期格式化處理的實(shí)現(xiàn)5. Java使用Tesseract-Ocr識(shí)別數(shù)字6. 完美解決vue 中多個(gè)echarts圖表自適應(yīng)的問(wèn)題7. Python使用urlretrieve實(shí)現(xiàn)直接遠(yuǎn)程下載圖片的示例代碼8. SpringBoot+TestNG單元測(cè)試的實(shí)現(xiàn)9. 在Chrome DevTools中調(diào)試JavaScript的實(shí)現(xiàn)10. 解決Android Studio 格式化 Format代碼快捷鍵問(wèn)題
