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

python進(jìn)程間通信Queue工作過程詳解

 更新時(shí)間：2019年11月01日 15:23:16   作者：張風(fēng)閑  
這篇文章主要介紹了python進(jìn)程間通信Queue工作過程詳解,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

Process之間有時(shí)需要通信，操作系統(tǒng)提供了很多機(jī)制來實(shí)現(xiàn)進(jìn)程間的通信。

1. Queue的使用

可以使用multiprocessing模塊的Queue實(shí)現(xiàn)多進(jìn)程之間的數(shù)據(jù)傳遞，Queue本身是一個(gè)消息列隊(duì)程序，首先用一個(gè)小實(shí)例來演示一下Queue的工作原理：

import multiprocessing

q = multiprocessing.Queue(3) # 初始化的Queue對(duì)象，最多能put三條消息
q.put("消息1")
q.put("消息2")
print(q.full())
q.put("消息3")
print(q.full())

# 因?yàn)橄⒘嘘?duì)已滿下面的try都會(huì)拋出異常，第一個(gè)try會(huì)等待2秒后再拋出異常，第二個(gè)Try會(huì)立刻拋出異常
try:
    q.put("消息4", True, 2)
except:
    print("消息已滿，現(xiàn)有的消息為%d" % (q.qsize()))

try:
    q.put_nowait("消息4")
except:
    print("消息已滿，現(xiàn)有的消息為%d" % (q.qsize()))

# 推薦的方式，先判斷消息列隊(duì)是否已滿，再寫入
if not q.full():
    q.put_nowait("消息4")

# 讀取消息時(shí)，先判斷消息列隊(duì)是否為空，再讀取
if not q.empty():
    for i in range(q.qsize()):
        print(q.get_nowait())

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

False
True
消息已滿，現(xiàn)有的消息為3
消息已滿，現(xiàn)有的消息為3
消息1
消息2
消息3

說明：

初始化Queue()對(duì)象時(shí)（例如：q=Queue()），若括號(hào)中沒有指定最大可接收的消息數(shù)量，或數(shù)量為負(fù)值，那么就代表可接受的消息數(shù)量沒有上限（直到內(nèi)存的盡頭）；

  • Queue.qsize()：返回當(dāng)前隊(duì)列包含的消息數(shù)量；
  • Queue.empty()：如果隊(duì)列為空，返回True，反之False ；
  • Queue.full()：如果隊(duì)列滿了，返回True,反之False；
  • Queue.get([block[, timeout]])：獲取隊(duì)列中的一條消息，然后將其從列隊(duì)中移除，block默認(rèn)值為True

1）如果block使用默認(rèn)值，且沒有設(shè)置timeout（單位秒），消息列隊(duì)如果為空，此時(shí)程序?qū)⒈蛔枞ㄍＴ谧x取狀態(tài)），直到從消息列隊(duì)讀到消息為止，如果設(shè)置了timeout，則會(huì)等待timeout秒，若還沒讀取到任何消息，則拋出"Queue.Empty"異常；

2）如果block值為False，消息列隊(duì)如果為空，則會(huì)立刻拋出"Queue.Empty"異常；

  • Queue.get_nowait()：相當(dāng)Queue.get(False)；
  • Queue.put(item,[block[, timeout]])：將item消息寫入隊(duì)列，block默認(rèn)值為True；

1）如果block使用默認(rèn)值，且沒有設(shè)置timeout（單位秒），消息列隊(duì)如果已經(jīng)沒有空間可寫入，此時(shí)程序?qū)⒈蛔枞ㄍＴ趯懭霠顟B(tài)），直到從消息列隊(duì)騰出空間為止，如果設(shè)置了timeout，則會(huì)等待timeout秒，若還沒空間，則拋出"Queue.Full"異常；

2）如果block值為False，消息列隊(duì)如果沒有空間可寫入，則會(huì)立刻拋出"Queue.Full"異常；

Queue.put_nowait(item)：相當(dāng)Queue.put(item, False)；

2. Queue實(shí)例

我們以Queue為例，在父進(jìn)程中創(chuàng)建兩個(gè)子進(jìn)程，一個(gè)往Queue里寫數(shù)據(jù)，一個(gè)從Queue里讀數(shù)據(jù)：

import multiprocessing
import time
import random


def write(q):
    """忘隊(duì)列中寫入數(shù)據(jù)"""
    for value in "ABCD":
        print("Put %s to queue" % (value))
        q.put(value)
        time.sleep(random.random())


def read(q):
    """讀取隊(duì)列中的數(shù)據(jù)"""
    while True:
        if not q.empty():
            value = q.get(True)
            print("Get %s from queue" % (value))
            time.sleep(random.random())
        else:
            break


if __name__ == "__main__":

    q = multiprocessing.Queue()

    pw = multiprocessing.Process(target=write, args=(q,))
    pr = multiprocessing.Process(target=read, args=(q,))

    pw.start()
    pw.join()

    pr.start()
    pr.join()
  
    print('')
    print('所有數(shù)據(jù)都寫入并且讀完')

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

Put A to queue
Put B to queue
Put C to queue
Put D to queue
Get A from queue
Get B from queue
Get C from queue
Get D from queue

所有數(shù)據(jù)都寫入并且讀完

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

相關(guān)文章

最新評(píng)論