欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Python進(jìn)程間通信multiprocess代碼實(shí)例

 更新時(shí)間：2020年03月18日 08:54:51   作者：flag_HW  
這篇文章主要介紹了Python進(jìn)程間通信multiprocess代碼實(shí)例,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

仔細(xì)說來，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)程沒有任何共享狀態(tài)，進(jìn)程修改的數(shù)據(jù)，改動(dòng)僅限于該進(jìn)程內(nèi)，但是通過一些特殊的方法，可以實(shí)現(xiàn)進(jìn)程之間數(shù)據(jù)的共享。

有了之前多線程使用以及線程間queue的基礎(chǔ)，多進(jìn)程以及進(jìn)程間通信就很好理解了，下面是多進(jìn)程基本語法以及進(jìn)程間通信簡單示例

#多進(jìn)程基本語法
import multiprocessing, time, os

def 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)程queue
def 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ù)

以上就是本文的全部內(nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

相關(guān)文章

最新評(píng)論