Python語法學習之程序間的通訊方式

# coding:utf-8


import json
import multiprocessing


class Work(object):     # 定義一個 Work 類
    def __init__(self, queue):      # 建構函式傳入一個 '佇列物件' --> queue
            self.queue = queue

    def send(self, message):        # 定義一個 send(傳送) 函數，傳入 message
                                    # [這裡有個隱藏的bug，就是隻判斷了傳入的是否字串型別；如果傳入的是函數、類、集合等依然會報錯]
        if not isinstance(message, str):    # 判斷傳入的 message 是否為字串，若不是，則進行 json 序列化
            message = json.dumps(message)
        self.queue.put(message)     # 利用 queue 的佇列範例化物件將 message 傳送出去

    def receive(self):      # 定義一個 receive(接收) 函數，不需傳入引數，但是因為接收是一個源源不斷的過程，所以需要使用 while 迴圈
        while 1:
            result = self.queue.get()   # 獲取 '佇列物件' --> queue 傳入的message
                                        # 由於我們接收的 message 可能不是一個字串，所以要程序異常的捕獲
            try:                        # 如果傳入的 message 符合 JSON 格式將賦值給 res ；若不符合，則直接使用 result 賦值 res
                res = json.loads(result)
            except:
                res = result
            print('接收到的資訊為：{}'.format(res))


if __name__ == '__main__':
    queue = multiprocessing.Queue()
    work = Work(queue)
    send = multiprocessing.Process(target=work.send, args=({'message': '這是一條測試的訊息'},))
    receive = multiprocessing.Process(target=work.receive)

    send.start()
    receive.start()

# coding:utf-8


import json
import time
import multiprocessing


class Work(object):     # 定義一個 Work 類
    def __init__(self, queue):      # 建構函式傳入一個 '佇列物件' --> queue
            self.queue = queue

    def send(self, message):        # 定義一個 send(傳送) 函數，傳入 message
                                    # [這裡有個隱藏的bug，就是隻判斷了傳入的是否字串型別；如果傳入的是函數、類、集合等依然會報錯]
        if not isinstance(message, str):    # 判斷傳入的 message 是否為字串，若不是，則進行 json 序列化
            message = json.dumps(message)
        self.queue.put(message)     # 利用 queue 的佇列範例化物件將 message 傳送出去


    def send_all(self):             # 定義一個 send_all(傳送)函數，然後通過for迴圈模擬批次傳送的 message
        for i in range(20):
            self.queue.put('第 {} 次迴圈，傳送的訊息為：{}'.format(i, i))
            time.sleep(1)



    def receive(self):      # 定義一個 receive(接收) 函數，不需傳入引數，但是因為接收是一個源源不斷的過程，所以需要使用 while 迴圈
        while 1:
            result = self.queue.get()   # 獲取 '佇列物件' --> queue 傳入的message
                                        # 由於我們接收的 message 可能不是一個字串，所以要程序異常的捕獲
            try:                        # 如果傳入的 message 符合 JSON 格式將賦值給 res ；若不符合，則直接使用 result 賦值 res
                res = json.loads(result)
            except:
                res = result
            print('接收到的資訊為：{}'.format(res))


if __name__ == '__main__':
    queue = multiprocessing.Queue()
    work = Work(queue)
    send = multiprocessing.Process(target=work.send, args=({'message': '這是一條測試的訊息'},))
    receive = multiprocessing.Process(target=work.receive)
    send_all = multiprocessing.Process(target=work.send_all,)


    send_all.start()    # 這裡因為 send 只執行了1次，然後就結束了。而 send_all 卻要回圈20次，它的執行時間是最長的，資訊也是傳送的最多的
    send.start()
    receive.start()

    # send.join()       # 使用 send 的阻塞會造成 send_all 迴圈還未結束 ，receive.terminate() 函數接收端就會終結。
    send_all.join()     # 所以我們只需要阻塞最長使用率的程序就可以了
    receive.terminate()