麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁 > 開發 > Python > 正文

Python 進程操作之進程間通過隊列共享數據,隊列Queue簡單示例

2024-09-09 19:02:11
字體:
來源:轉載
供稿:網友

本文實例講述了Python 進程操作之進程間通過隊列共享數據,隊列Queue。分享給大家供大家參考,具體如下:

隊列中的數據是放在內存中的,可以通過分布式緩存redis優化隊列。

demo.py(進程通過隊列共享數據):

import multiprocessingdef download_from_web(q):  """下載數據"""  # 模擬從網上下載的數據  data = [11, 22, 33, 44]  # 向隊列中寫入數據  for temp in data:    q.put(temp) # 隊列中寫數據,隊列滿了會阻塞。 put_nowait() 隊列滿了會拋異常  print("---下載器已經下載完了數據并且存入到隊列中----")def analysis_data(q):  """數據處理"""  waitting_analysis_data = list()  # 從隊列中獲取數據  while True:    data = q.get() # 隊列中讀數據,隊列空了會阻塞。 get_nowait() 隊列空了會拋異常    waitting_analysis_data.append(data)    if q.empty(): # 隊列是否為空。 q.full() 隊列是否滿了。      break  # 模擬數據處理  print(waitting_analysis_data)def main():  # 1. 創建一個隊列 (先進先出)  q = multiprocessing.Queue(10) # 最多放10個數據。 如果不指定長度,默認最大(和硬件相關)  # 2. 創建多個進程,將隊列的引用當做實參進行傳遞  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()

運行結果:

---下載器已經下載完了數據并且存入到隊列中----
[11, 22, 33, 44]

更多關于Python相關內容感興趣的讀者可查看本站專題:《Python進程與線程操作技巧總結》、《Python數據結構與算法教程》、《Python函數使用技巧總結》、《Python字符串操作技巧匯總》、《Python入門與進階經典教程》、《Python+MySQL數據庫程序設計入門教程》及《Python常見數據庫操作技巧匯總》

希望本文所述對大家Python程序設計有所幫助。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 欧美福利视频一区二区 | 久久人添人人爽人人爽人人片av | 欧美黄色视屏 | 污片视频在线观看 | 精品国产一区二区三区四区在线 | 久久久久久久久久久影视 | 国产精品亚洲欧美一级在线 | 亚洲第一成人久久网站 | 激情综合网俺也去 | 午夜精品久久久久久久99热浪潮 | 嫩呦国产一区二区三区av | 视频一区 在线 | 免费永久看羞羞片网站入口 | 日本看片一区二区三区高清 | 色啪综合 | 久久精品中文字幕 | 日本精品婷婷久久爽一下 | 久草在线公开视频 | 成人福利在线播放 | 欧美黄一区 | 亚洲射吧 | 久久美女免费视频 | 久久精品欧美视频 | 久久成人国产精品 | 九九热这里只有精品8 | 91久久91久久精品免观看 | 免费1级做55爰片l在线观看 | japanese javhd| 97黄色网 | 曰韩毛片| 黄色一级电影网 | 亚洲成在人| 狠狠干五月天 | 国产婷婷一区二区三区 | 欧美aⅴ视频 | 久久国产精品小视频 | www.91在线观看 | 看免费一级毛片 | 精品一区二区在线播放 | 一区二区三区在线视频观看58 | 久久露脸国语精品国产91 |