#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time     : 2018/8/20 17:01
# @Author   :



# 多程序
from multiprocessing import Process
import os

# 子程序要執行的程式碼
def run_proc(name):
    print("Run child process %s ((%s)"%(name,os.getppid()))

if __name__ == '__main__':
    print("Parent process %s."%os.getpid())
    p = Process(target=run_proc,args=('test',))
    print('Child process will start.')
    p.start()
    p.join() #等待子程序結束後再繼續往下執行，通常用於程序間的同步
    print("Child process end.")
 

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time     : 2018/8/20 17:06
# @Author   :

# 要啟動大量的子程序，可以用程序池的方式批量建立子程序：
from multiprocessing import Pool
import os,time,random
def long_time_task(name):
    print('Run task %s (%s)..'%(name,os.getpid()))
    start =time.time()
    time.sleep(random.random()*3)
    end = time.time()
    print('Task %s runs %0.2f seconds.'%(name,(end-start)))

if __name__ == '__main__':
    print('Parent process %s.'%os.getpid())
    p =Pool(4) # 引數 4表示可以同時跑4個執行緒 可以不賦值 預設cpu核數
    for i in range(5):
        p.apply_async(long_time_task,args=(i,))
    print('Waiting for all subProcess done...')
    p.close()
    p.join() #對Pool物件呼叫join()方法會等待所有子程序執行完畢，呼叫join()之前必須先呼叫close()，呼叫close()之後就不能繼續新增新的Process了
    print('All subProcess done.')
 

#!/usr/bin/env python
# -*- coding: utf-8 -*-
# @Time     : 2018/8/20 17:21
# @Author   :

# 程序之間的通訊 提供了Queue、Pipes等多種方式來交換資料。
from multiprocessing import  Process,Queue
import os,time,random

# 寫程序執行的程式碼
def write(q):
    print('Process to write:%s'%os.getpid())
    for value in range(ord('A'),ord('D')):
        print('Put %s to queue...' %chr(value))
        q.put(chr(value))
        time.sleep(random.random())
# 讀資料程序執行的程式碼
def read(q):
    print('Process to read: %s' %os.getpid())
    while True:
        value = q.get(True)
        print('Get %s from queue.'%value)

if __name__ =='__main__':
    # 父程序建立Queue 並傳輸給各個子程序
    q = Queue()
    pw = Process(target=write,args=(q,))
    pr = Process(target=read,args=(q,))
    # 啟動程序
    pw.start()
    pr.start()
    #等待pw結束
    pw.join()
    # pr是死迴圈 無法結束 強制結束
    pr.terminate()