多程序指的是乙個程式可以啟動多個程序執行,一般模式如下:
以上**在主程序中建立子程序,並輸出程序名和編號,等待 join 子程序執行完,再繼續執行主程序的整個的執行流程。結果如下:import multiprocessing
from multiprocessing import process,current_process
import time
# cup 核數量
num_cpus = multiprocessing.cpu_count()
def func(x):
time.sleep(1)
proc = current_process()
print proc.name,"--",proc.pid,"--",x
# 建立子程序
sub_proc = process(target = func,args = ("oyp",)) # 同多執行緒類似
sub_proc.start()
proc = current_process()
sub_proc.join()
print proc.name,"--",proc.pid
程序同步
鎖是為了確保資料一致性,比如讀寫鎖,每個程序給乙個變數增加 1 ,但是如果在乙個程序讀取但還沒有寫入的時候,另外的程序也同時讀取了,並寫入該值,則最後寫入的值是錯誤的,這時候就需要鎖。跟多執行緒情況類似。
兩個程序之間的通訊 pipefrom multiprocessing import process,lock
def func():
lock = lock()
lock.acquire()
#do my update
lock.release()
sub_proc = process(target = func)
sub_proc.start()
sub_proc.join()
結果如下:from multiprocessing import process,pipe
#定義傳送程序
def func1(pipe,y):
for x in range(10):
pipe.send(y+str(x))
#定義接受程序
def func2(pipe):
while true:
print "func2 recv %s" %pipe.recv()
pipe = pipe(true) # true 表示全雙工, 預設或不填為單工
process(target = func1,args = (pipe[0],"oyp",)).start() # 啟動第乙個程序
process(target = func2,args = (pipe[1],)).start() # 啟動第二個程序
記憶體共享
在提到多執行緒程式設計的時候提到過,多程序預設是不支援記憶體共享的,也就是同乙個變數在不同的程序中其實是不一樣的,如果要使用記憶體共享,比較通用的乙個寫法是 manager ,當然其實也有別的方法實現共享:
程序池from multiprocessing import process,manager
def func(dit,lst):
dit[1] = 1
lst.reverse()
manager = manager()
dit = manager.dict()
lst = manager.list(range(5,10))
p = process(target = func,args = (dit,lst,))
p.start()
p.join() # 等待子程序執行完畢再看結果
print dit,lst
from multiprocessing import pool
def func(x):
return x*x
pool = pool(processes = 4)
print pool.map(func,range(8)) # 非同步執行 print pool.map_async(func,range(8)).get()
print 輸出: [0, 1, 4, 9, 16, 25, 36, 49]
pool.close() # 不再接受新的任務
pool.join() # 等待程序池中的程序全部結束
python多程序 Python多程序程式設計詳解
本文 在 python 3.6 環境下測試通過。多程序 multiprocessing 模組是在 python 2.6 版本中加入的,和多執行緒 threading 模組類似,都是用來做並行運算的。不過python既然有了threading,為什麼還要搞乙個multiprocessing呢?這是因為...
python多程序程式設計
python多程序程式設計。最近開始學習python程式語言,詳細參照 python絕技運用python成為頂級黑客 在學習過程第一章節中,編寫破解linux shadow檔案時,想利用多執行緒加快破解速度。主機執行環境為windows下的vm workstation上的一台虛擬機器,執行多執行緒 ...
Python 多程序程式設計
import multiprocessing import time import osimport random g nums 11,22,33 deftest1 while true print 子程序pid d,父程序pid d os.getpid os.getppid time.sleep ...