python高級編程——進程和進程池

python提供了一個跨平臺的多進程支持——multiprocessing模塊，其包含Process類來代表一個進程對象

　　1、Process語法結構：（註： 傳參的時候一定使用關鍵字傳參）

# 自定義進程類
class ProcessClass(Process):
    g_num = 100

    def __init__(self, interval):
        # 這行代碼必須添加上
        super().__init__()
        self.interval = interval
        self.result = "初始化"

    def run(self):
        global g_num
        g_num = 120
        print("子進程{}，開始執行，父進程為{}".format(os.getpid(), os.getppid()))
        start = time.time()
        time.sleep(2)
        stop = time.time()
        print("{}執行結束，耗時{:0.2f}秒".format(os.getpid(), stop-start))
        self.result = "運行之後的結果"


if __name__ == "__main__":
    t_start = time.time()
    print("當前進程{}".format(os.getpid()))
    p = ProcessClass(2)
    p.start()
    p.join()
    t_stop = time.time()
    # 數據隔離
    print("子進程 任務 運行結果：", p.result)   # -----> 初始化 數據未改變
    print(ProcessClass.g_num)    # ------>100  數據未改變
    print("(%s)執行結束，耗時%0.2f" % (os.getpid(), t_stop - t_start))

　　　 實例如下：

# 自定義進程類
class ProcessClass(Process):
    g_num = 100

    def __init__(self, interval, q):
        # 這行代碼必須添加上
        super().__init__()
        self.interval = interval
        self.result = "初始化"
        # 初始化一個隊列實例化對象
        self.q = q

    def run(self):
        global g_num
        g_num = 120
        print("子進程{}，開始執行，父進程為{}".format(os.getpid(), os.getppid()))
        start = time.time()
        time.sleep(self.interval)
        stop = time.time()
        print("{}執行結束，耗時{:0.2f}秒".format(os.getpid(), stop-start))
        self.result = "運行之後的結果"
        # 將消息（數據）添加到隊列中
        self.q.put(g_num)
        self.q.put(self.result)

    def get_data(self):
        return self.result


if __name__ == "__main__":
    # 初始化一個隊列實例化對象，參數為隊列的長度
    queues = Queue(5)
    print("當前進程{}".format(os.getpid()))
    p = ProcessClass(2, queues)
    t_start = time.time()
    p.start()
    p.join()
    t_stop = time.time()
    # 數據隔離
    print("子進程 任務 運行結果：", p.get_data())   # -----> 初始化 數據未改變
    print(ProcessClass.g_num)  # ------>100  數據未改變
    print("子進程 任務 運行結果：", queues.get())  # -----> 120 數據未改變
    print("子進程 任務 運行結果：", queues.get())  # -----> 運行之後的結果 數據未改變
    print("(%s)執行結束，耗時%0.2f" % (os.getpid(), t_stop - t_start))

# 進程池
def worker(msg):
    start = time.time()
    print("{}開始執行，進程號為{}".format(msg, os.getpid()))
    # random.random()生成0~1之間的隨機數
    time.sleep(random.random()*3)
    # time.sleep(3)
    stop = time.time()
    print(msg, "執行完畢，耗時{:.2f}".format(stop-start))


if __name__ == "__main__":
    # 定義一個進程池，最大數為3
    po = Pool(3)
    for i in range(10):
        # 非阻塞式操作Pool.apply_async(要調用的目標，(傳遞給目標的參數元組，))
        # 每次迴圈將會用空閑出來的子進程去調用目標
        po.apply_async(worker, (i, ))
        # 阻塞式操作
        # po.apply(worker, (i, ))
    print("start".center(24, "-"))
    po.close()
    po.join()
    print("end".center(24, "-"))