Python 中通過佇列來實現程序間通訊

python程式中，在程序和程序之間是不共享全域性變數的資料的。

我們來看乙個例子：

from multiprocessing import process
import os
import time
nums =[11
,22]def
work1()
:"""子程序要執行的**"""
print
("in process1 pid=%d ,nums=%s"
%(os.getpid(
), nums)
)for i in
range(3
):time.sleep(1)
print
("in process1 pid=%d ,nums=%s"
%(os.getpid(
), nums)
)def
work2()
:"""子程序要執行的**"""
print
("in process2 pid=%d ,nums=%s"
%(os.getpid(
), nums)
)if __name__ ==
'__main__'
: p1 = process(target=work1)
p1.start(
) p1.join(
) p2 = process(target=work2)
p2.start(
)

程序 p1 裡對全域性變數 nums 迴圈進行處理，程序 p2 將 nums 列印出來，發現 nums 的值沒有變化。

執行結果：

in process1 pid=5788 ,nums=[11, 22]
in process1 pid=5788 ,nums=[11, 22, 0]
in process1 pid=5788 ,nums=[11, 22, 0, 1]
in process1 pid=5788 ,nums=[11, 22, 0, 1, 2]
in process2 pid=11832 ,nums=[11, 22]

通過佇列完成程序間通訊

但是程序(process)之間有時需要通訊，作業系統提供了很多機制來實現程序間的通訊。

可以使用 multiprocessing 模組的 queue 實現多程序之間的資料傳遞。

queue 本身是乙個訊息佇列程式，首先用乙個小例項來演示一下 queue 的工作原理：

from multiprocessing import queue
# 初始化乙個queue物件，最多可接收三條put訊息
q = queue(
3) 
q.put(
"訊息1"
)q.put(
"訊息2"
)print
(q.full())
# false
q.put(
"訊息3"
)print
(q.full())
# true
# 因為訊息佇列已滿下面的try都會丟擲異常
# 第乙個try會等待2秒後再丟擲異常
try:
q.put(
"訊息4"
,true,2
)except
:print
("訊息佇列已滿，現有訊息數量:%s"
% q.qsize())
# 第二個try會立刻丟擲異常
try:
q.put_nowait(
"訊息4"
)except
:print
("訊息列隊已滿，現有訊息數量:%s"
% q.qsize())
# 推薦的方式，先判斷訊息列隊是否已滿，再寫入
ifnot q.full():
q.put_nowait(
"訊息4"
)# 讀取訊息時，先判斷訊息列隊是否為空，再讀取
ifnot q.empty():
for i in
range
(q.qsize())
:print
(q.get_nowait(
))

執行結果：

佇列 queue 的使用說明

初始化 queue()物件時（例如：q=queue()），若括號中沒有指定最大可接收的訊息數量，或數量為負值，那麼就代表可接受的訊息數量沒有上限（直到記憶體的盡頭）。

queue.qsize()：返回當前佇列包含的訊息數量。

queue.empty()：如果隊列為空，返回true，反之false。

queue.full()：如果佇列滿了，返回true，反之false。

queue.get([block[, timeout]])：獲取佇列中的一條訊息，然後將其從列隊中移除，block 預設值為 true。

如果 block 使用預設值，且沒有設定 timeout（單位秒），訊息佇列如果為空，此時程式將被阻塞，停在讀取狀態，直到從訊息佇列讀到訊息為止；如果設定了 timeout，則會等待 timeout 秒，若還沒讀取到任何訊息，則丟擲「queue.empty」異常。

如果 block 值為 false，訊息列隊如果為空，則會立刻丟擲「queue.empty」異常。

queue.get_nowait()：相當 queue.get(false)。

queue.put(item,[block[, timeout]])：將 item 訊息寫入佇列，block 預設值為 true。

如果 block 使用預設值，且沒有設定 timeout（單位秒），訊息佇列如果已經沒有空間可寫入，此時程式將被阻塞，停在寫入狀態，直到從訊息佇列騰出空間為止；如果設定了timeout，則會等待 timeout 秒，若還沒空間，則丟擲「queue.full」異常。

如果 block 值為 false，訊息佇列如果沒有空間可寫入，則會立刻丟擲「queue.full」異常。

queue.put_nowait(item)：相當queue.put(item, false)。

queue例項

我們以 queue 為例，在父程序中建立兩個子程序，乙個往 queue 裡寫資料，乙個從 queue 裡讀資料。

from multiprocessing import process, queue
import os
import time
import random
defwrite
(q):
# 寫資料程序執行的**:
for value in
['a'
,'b'
,'c']:
print
('put %s to queue...'
% value)
q.put(value)
time.sleep(random.random())
defread
(q):
# 讀資料程序執行的**:
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__'
:# 父程序建立queue，並傳給各個子程序：
q = queue(
) pw = process(target=write, args=
(q,)
) pr = process(target=read, args=
(q,)
)# 啟動子程序pw，寫入:
pw.start(
)# 等待pw結束:
pw.join(
)# 啟動子程序pr，讀取:
pr.start(
) pr.join(
)print(''
)print
('所有資料都寫入並且讀完'
)

執行結果：

Python 中通過佇列來實現程序間通訊

Python 中通過佇列來實現程序間通訊

Unity中通過PlayerPrefs進行資料儲存

在Sqlite中通過Replace來實現插入和更新

Python 中通過佇列來實現程序間通訊

Python 中通過佇列來實現程序間通訊

Unity中通過PlayerPrefs進行資料儲存

在Sqlite中通過Replace來實現插入和更新

相關推薦