這篇文章將為大家詳細(xì)講解有關(guān)Python中怎么實(shí)現(xiàn)進(jìn)程間通過(guò)隊(duì)列共享數(shù)據(jù)，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

創(chuàng)新互聯(lián)公司是一家從事企業(yè)網(wǎng)站建設(shè)、成都網(wǎng)站設(shè)計(jì)、成都做網(wǎng)站、行業(yè)門戶網(wǎng)站建設(shè)、網(wǎng)頁(yè)設(shè)計(jì)制作的專業(yè)網(wǎng)站建設(shè)公司，擁有經(jīng)驗(yàn)豐富的網(wǎng)站建設(shè)工程師和網(wǎng)頁(yè)設(shè)計(jì)人員，具備各種規(guī)模與類型網(wǎng)站建設(shè)的實(shí)力，在網(wǎng)站建設(shè)領(lǐng)域樹(shù)立了自己獨(dú)特的設(shè)計(jì)風(fēng)格。自公司成立以來(lái)曾獨(dú)立設(shè)計(jì)制作的站點(diǎn)千余家。

隊(duì)列中的數(shù)據(jù)是放在內(nèi)存中的，可以通過(guò)分布式緩存redis優(yōu)化隊(duì)列。

demo.py（進(jìn)程通過(guò)隊(duì)列共享數(shù)據(jù)）：

import multiprocessing
def download_from_web(q):
  """下載數(shù)據(jù)"""
  # 模擬從網(wǎng)上下載的數(shù)據(jù)
  data = [11, 22, 33, 44]
  # 向隊(duì)列中寫(xiě)入數(shù)據(jù)
  for temp in data:
    q.put(temp) # 隊(duì)列中寫(xiě)數(shù)據(jù),隊(duì)列滿了會(huì)阻塞。 put_nowait() 隊(duì)列滿了會(huì)拋異常
  print("---下載器已經(jīng)下載完了數(shù)據(jù)并且存入到隊(duì)列中----")
def analysis_data(q):
  """數(shù)據(jù)處理"""
  waitting_analysis_data = list()
  # 從隊(duì)列中獲取數(shù)據(jù)
  while True:
    data = q.get() # 隊(duì)列中讀數(shù)據(jù),隊(duì)列空了會(huì)阻塞。 get_nowait() 隊(duì)列空了會(huì)拋異常
    waitting_analysis_data.append(data)
    if q.empty(): # 隊(duì)列是否為空。 q.full() 隊(duì)列是否滿了。
      break
  # 模擬數(shù)據(jù)處理
  print(waitting_analysis_data)
def main():
  # 1. 創(chuàng)建一個(gè)隊(duì)列 (先進(jìn)先出)
  q = multiprocessing.Queue(10) # 最多放10個(gè)數(shù)據(jù)。 如果不指定長(zhǎng)度,默認(rèn)大(和硬件相關(guān))
  # 2. 創(chuàng)建多個(gè)進(jìn)程，將隊(duì)列的引用當(dāng)做實(shí)參進(jìn)行傳遞
  p1 = multiprocessing.Process(target=download_from_web, args=(q,))
  p2 = multiprocessing.Process(target=analysis_data, args=(q,))
  p1.start()
  p2.start()
if __name__ == "__main__":
  main()

運(yùn)行結(jié)果：

---下載器已經(jīng)下載完了數(shù)據(jù)并且存入到隊(duì)列中----
[11, 22, 33, 44]

關(guān)于Python中怎么實(shí)現(xiàn)進(jìn)程間通過(guò)隊(duì)列共享數(shù)據(jù)就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺(jué)得文章不錯(cuò)，可以把它分享出去讓更多的人看到。

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場(chǎng)景需求。

分享名稱：Python中怎么實(shí)現(xiàn)進(jìn)程間通過(guò)隊(duì)列共享數(shù)據(jù)-創(chuàng)新互聯(lián)
當(dāng)前路徑：http://www.xueling.net.cn/article/djedoh.html