程序間通訊-queue
process之間有時需要通訊，作業系統提供了很多機制來實現程序間的通訊。
queue的使用
可以使用multiprocessing模組的queue實現多程序之間的資料傳遞，queue本身是乙個訊息列隊程式，首先用乙個小例項來演示一下queue的工作原理：
#coding=utf-8
from multiprocessing import queue
q=queue(3) #初始化乙個queue物件，最多可接收三條put訊息
q.put("訊息1")
q.put("訊息2")
print(q.full()) #false
q.put("訊息3")
print(q.full()) #true
#因為訊息列隊已滿下面的try都會丟擲異常，第乙個try會等待2秒後再丟擲異常，第二個try會立刻丟擲異常
try:
q.put("訊息4",true,2)
except:
print("訊息列隊已滿，現有訊息數量:%s"%q.qsize())
try:
q.put_nowait("訊息4")
except:
print("訊息列隊已滿，現有訊息數量:%s"%q.qsize())
#推薦的方式，先判斷訊息列隊是否已滿，再寫入
if not q.full():
q.put_nowait("訊息4")
#讀取訊息時，先判斷訊息列隊是否為空，再讀取
if not q.empty():
for i in range(q.qsize()):
print(q.get_nowait())
false
true
訊息列隊已滿，現有訊息數量:3
訊息列隊已滿，現有訊息數量:3
訊息1訊息2
訊息3
初始化queue()物件時（例如：q=queue()），若括號中沒有指定最大可接收的訊息數量，或數量為負值，那麼就代表可接受的訊息數量沒有上限（直到記憶體的盡頭）；
queue.qsize()：返回當前佇列包含的訊息數量；
queue.empty()：如果隊列為空，返回true，反之false ；
queue.full()：如果佇列滿了，返回true,反之false；
queue.get([block[, timeout]])：獲取佇列中的一條訊息，然後將其從列隊中移除，block預設值為true；
1）如果block使用預設值，且沒有設定timeout（單位秒），訊息列隊如果為空，此時程式將被阻塞（停在讀取狀態），直到從訊息列隊讀到訊息為止，如果設定了timeout，則會等待timeout秒，若還沒讀取到任何訊息，則丟擲"queue.empty"異常；
2）如果block值為false，訊息列隊如果為空，則會立刻丟擲"queue.empty"異常；
queue.get_nowait()：相當queue.get(false)；
queue.put(item,[block[, timeout]])：將item訊息寫入佇列，block預設值為true；
1）如果block使用預設值，且沒有設定timeout（單位秒），訊息列隊如果已經沒有空間可寫入，此時程式將被阻塞（停在寫入狀態），直到從訊息列隊騰出空間為止，如果設定了timeout，則會等待timeout秒，若還沒空間，則丟擲"queue.full"異常；
2）如果block值為false，訊息列隊如果沒有空間可寫入，則會立刻丟擲"queue.full"異常；
queue.put_nowait(item)：相當queue.put(item, false)；
2. queue例項
我們以queue為例，在父程序中建立兩個子程序，乙個往queue裡寫資料，乙個從queue裡讀資料：
from multiprocessing import process, queue
import os, time, random
# 寫資料程序執行的**:
def write(q):
for value in ['a', 'b', 'c']:
print('put %s to queue...' % value)
q.put(value)
time.sleep(random.random())
# 讀資料程序執行的**:
def read(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()
# pr程序裡是死迴圈，無法等待其結束，只能強行終止:
print('')
print('所有資料都寫入並且讀完')
python 多程序 高階 程序間通訊之Queue
假如建立了大量的程序，那程序間通訊是必不可少的。python提供了多種程序間通訊的方式，如 queue和pipe方法。他們兩者的區別在於pipe常用來在兩個程序間通訊，queue用來在多個程序間實現通訊 queue是多程序安全的佇列，可以使用queue實現多程序之間的資料傳遞。有兩個方法 put 和...
Python的程序間通訊
程序間通訊有多種方式，包括訊號，管道，訊息佇列，訊號量，共享記憶體，socket等 1.共享記憶體 python可以通過mmap模組實現程序之間的共享記憶體 mmap檔案物件既像乙個字串也像乙個普通檔案物件。像字串時因為我們可以改變其中的單個字元，如，obj index a 同時我們也可以改變一小段...
Python多程序 程序間通訊
1.使用multiprocessing模組建立的程序之間的通訊 coding utf 8 queue類常用屬性和方法 init self,maxsize 1 qsize full empty put obj,block true,timeout none put nowait obj get blo...