# _*_ 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("消息隊列已滿，現(xiàn)有消息數(shù)量:%s" % q.qsize())

    try:
        q.put_nowait("消息4")
    except:
        print("消息隊列已滿，現(xiàn)有消息數(shù)量:%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
# 向隊列中寫入數(shù)據(jù)
def write_task(q):
    if not q.full():
        for i in range(5):
            message = "消息" + str(i)
            q.put(message)
            print("寫入：%s" % message)
# 從隊列中讀取數(shù)據(jù)
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()  # 父進程創(chuàng)建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("-------父進程結束-----------")