某個(gè)線(xiàn)程要共享數(shù)據(jù)時(shí)，先將其鎖定，此時(shí)資源的狀態(tài)為“鎖定”，其他線(xiàn)程不能更改；直到該線(xiàn)程釋放資源，將資源的狀態(tài)變成“非鎖定”，其他的線(xiàn)程才能再次鎖定該資源。互斥鎖保證了每次只有一個(gè)線(xiàn)程進(jìn)入寫(xiě)入操作，從而保證了多線(xiàn)程情況下數(shù)據(jù)的正確性。
采用f_flag的方法效率低
創(chuàng)建鎖
mutex=threading.Lock()
鎖定
mutex.acquire([blocking])#里面可以加blocking(等待的時(shí)間)或者不加，不加就會(huì)一直等待（堵塞）
釋放
mutex.release()
import threading from threading import Thread from threading import Lock import time thnum=0 #兩個(gè)線(xiàn)程都在搶著對(duì)這個(gè)鎖進(jìn)行上鎖，如果有一方成功上鎖，那么導(dǎo)致另外一方會(huì)堵塞（一直等待），到這個(gè)鎖被解開(kāi)為之 class MyThread(threading.Thread): def run(self): mutex.acquire() for i in range(10000): global thnum thnum+=1 print(thnum) mutex.release() def test(): global thnum mutex.acquire() #等待可以上鎖，通知而不是輪訓(xùn)，沒(méi)有占用CPU for i in range(10000): thnum+=1 print(thnum) mutex.release()#解鎖 mutex=Lock() if __name__=='__main__': t=MyThread() t.start() #創(chuàng)建一把互斥鎖，默認(rèn)是沒(méi)有上鎖的 thn=Thread(target=test) thn.start() ''''' 10000 20000 '''
只要一上鎖，由多任務(wù)變?yōu)閱稳蝿?wù),相當(dāng)于只有一個(gè)線(xiàn)程在運(yùn)行。
下面的代碼相對(duì)上面加鎖的時(shí)間變短了
import threading from threading import Thread from threading import Lock import time thnum=0 #兩個(gè)線(xiàn)程都在搶著對(duì)這個(gè)鎖進(jìn)行上鎖，如果有一方成功上鎖，那么導(dǎo)致另外一方會(huì)堵塞（一直等待），到這個(gè)鎖被解開(kāi)為之 class MyThread(threading.Thread): def run(self): for i in range(10000): mutex.acquire() global thnum thnum+=1 mutex.release()#釋放后，都開(kāi)始搶?zhuān)@樣上鎖的時(shí)間變短 print(thnum) def test(): global thnum for i in range(10000): mutex.acquire() thnum+=1 mutex.release()#解鎖 print(thnum) mutex=Lock() if __name__=='__main__': t=MyThread() t.start() #創(chuàng)建一把互斥鎖，默認(rèn)是沒(méi)有上鎖的 thn=Thread(target=test) thn.start() ''''' 10000 20000 '''
只有必須加鎖的地方才加鎖
同步：按照預(yù)定的先后順序執(zhí)行
一個(gè)運(yùn)行完后，釋放下一個(gè)，下一個(gè)鎖定后運(yùn)行，再釋放下一個(gè)，下一個(gè)鎖定后，運(yùn)行后釋放下一個(gè)..... 釋放第一個(gè)
異步：
#異步的實(shí)現(xiàn) from multiprocessing import Pool import time import os #getpid()獲取當(dāng)前進(jìn)程的進(jìn)程號(hào) #getppid()獲取當(dāng)前進(jìn)程的父進(jìn)程號(hào) def test():#子進(jìn)程 print("----進(jìn)程池中的進(jìn)程-----pid=%d,ppid=%d --"%(os.getpid(),os.getppid())) for i in range(3): print("-----%d----"%i) time.sleep(1) return "over" #子進(jìn)程執(zhí)行完后返回給操作系統(tǒng)，返回給父進(jìn)程 def test2(args): print("-----callback func----pid=%d"%os.getpid())#主進(jìn)程調(diào)用test2 print("------callback func---args=%s"%args) def main(): pool=Pool(3) pool.apply_async(func=test,callback=test2)#回調(diào) time.sleep(5)#收到func進(jìn)程結(jié)束后的信號(hào)后，執(zhí)行回調(diào)函數(shù)test2 print("----主進(jìn)程-pid = %d"%os.getpid()) if __name__=="__main__": #main() pool=Pool(3) pool.apply_async(test,callback=test2)#回調(diào) time.sleep(5)#收到func進(jìn)程結(jié)束后的信號(hào)后，執(zhí)行回調(diào)函數(shù)test2 print("----主進(jìn)程-pid = %d"%os.getpid()) '''''顯示結(jié)果不太正確，應(yīng)該先運(yùn)行test呀，再運(yùn)行test2 -----callback func----pid=7044 ------callback func---args=over ----主進(jìn)程-pid = 7044 ----進(jìn)程池中的進(jìn)程-----pid=3772,ppid=7044 -- -----0---- -----1---- -----2---- ''' 新聞熱點(diǎn)
疑難解答
圖片精選
網(wǎng)友關(guān)注
