Python通過佇列實現程序間通訊詳情

# _*_ coding:utf-8 _*_
from multiprocessing import Process
def plus():
    print("-------子程序1開始----------")
    global g_num
    g_num += 50
    print("g_num is %d" % g_num)
    print("-------子程序1結束----------")
def minus():
    print("-------子程序2開始----------")
    global g_num
    g_num -= 50
    print("g_num is %d" % g_num)
    print("-------子程序2結束----------")
g_num = 100  # 定義一個全域性變數
if __name__ == "__main__":
    print("-------主程序開始----------")
    print("g_num is %d" % g_num)
    p1 = Process(target=plus)  # 範例化程序p1
    p2 = Process(target=minus)  # 範例化程序p2
    p1.start()  # 開啟p1程序
    p2.start()  # 開啟p2程序
    p1.join()  # 等待p1程序結束
    p2.join()  # 等待p2程序結束
    print("-------主程序結束----------")

# _*_ coding:utf-8 _*_
from multiprocessing import Queue
if __name__ == "__main__":
    q = Queue(3)
    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.empty():
        print("-----從佇列中獲取訊息-------")
        for i in range(q.qsize()):
            print(q.get_nowait())
    # 先判讀訊息佇列是否已滿，再寫入：
    if not q.full():
        q.put_nowait("訊息4")

# _*_ coding:utf-8 _*_
from multiprocessing import Process, Queue
import time
# 向佇列中寫入資料
def write_task(q):
    if not q.full():
        for i in range(5):
            message = "訊息" + str(i)
            q.put(message)
            print("寫入：%s" % message)
# 從佇列中讀取資料
def read_task(q):
    time.sleep(1)  # 休眠1秒
    while not q.empty():
        print("讀取：%s" % q.get(True, 2))  # 等待2秒中，如果沒有讀取到任何資訊，則丟擲異常
if __name__ == "__main__":
    print("--------父程序開始---------")
    q = Queue()  # 父程序建立Queue，並傳給各個子程序
    pw = Process(target=write_task, args=(q,))  # 範例化寫入佇列的子程序，並傳遞給佇列
    pr = Process(target=read_task, args=(q,))  # 範例化讀取佇列的子程序，並傳遞給佇列
    pw.start()  # 啟動子程序pw，寫入
    pr.start()  # 啟動子程序pr，讀取
    pw.join()  # 等待pw結束
    pr.join()  # 等待pr結束
    print("-------父程序結束-----------")