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

?

multiprocessing模塊的Queue實(shí)現(xiàn)多進(jìn)程之間的數(shù)據(jù)傳遞，Queue本身是一個消息列隊程序

?

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

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

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

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

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

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

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

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

?

from multiprocessing import Queue

import time

?

q = Queue(3)? # 參數(shù)表明這個隊列最多只能保存3條數(shù)據(jù)

?

print("判斷隊列是否為空：%s" % q.empty())

print("判斷隊列是否為滿：%s" % q.full())

?

q.put(100)

print("新添加了一條數(shù)據(jù) 100")

?

# print("當(dāng)前隊列中數(shù)據(jù)的個數(shù)：%d" % q.qsize())

?

q.put(200)

print("新添加了一條數(shù)據(jù) 200")

q.put(300)

print("新添加了一條數(shù)據(jù) 300")

# q.put(400) ?# 默認(rèn)是阻塞的，表示如果隊列已滿，則等待，直到有空位置才能繼續(xù)添加新的數(shù)據(jù)

# print("新添加了一條數(shù)據(jù) 400")

?

q.put(400, timeout=3)? # timeout參數(shù)表示最長等待的時間，超時時間，單位秒，超過時間后，如果還不能添加，則拋出異常信息

print("新添加了一條數(shù)據(jù) 400")

?

time.sleep(0.1)

?

print("判斷隊列是否為空：%s" % q.empty())

print("判斷隊列是否為滿：%s" % q.full())

?

ret= q.get()

print(ret)

ret= q.get()

print(ret)

ret= q.get()

print(ret)

# ret = q.get() # 默認(rèn)是阻塞的，表示如果隊列已空，則等待，直到有新的數(shù)據(jù)出現(xiàn)，才能繼續(xù)取出元素

#print(ret)

ret = q.get(timeout=3)? # timeout參數(shù)表示最長等待的時間，超時時間，單位秒，超過時間后，如果還不能取出，則拋出異常信息

print(ret)

?

print("判斷隊列是否為空：%s" % q.empty())

print("判斷隊列是否為滿：%s" % q.full())

總結(jié)

以上是生活随笔為你收集整理的进程间通信-Queue 消息队列 先进先出的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。