快捷導(dǎo)航

Python 進(jìn)程操作之進(jìn)程間通過(guò)隊(duì)列共享數(shù)據(jù)，隊(duì)列Queue簡(jiǎn)單示例

更新時(shí)間：2019年10月11日 11:13:12 作者：houyanhua1

這篇文章主要介紹了Python 進(jìn)程操作之進(jìn)程間通過(guò)隊(duì)列共享數(shù)據(jù)，隊(duì)列Queue,結(jié)合實(shí)例形式分析了Python進(jìn)程數(shù)據(jù)共享、隊(duì)列數(shù)據(jù)處理相關(guān)操作技巧,需要的朋友可以參考下

本文實(shí)例講述了Python 進(jìn)程操作之進(jìn)程間通過(guò)隊(duì)列共享數(shù)據(jù)，隊(duì)列Queue。分享給大家供大家參考，具體如下：

隊(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é)果：