快捷導(dǎo)航

python互斥鎖、加鎖、同步機(jī)制、異步通信知識(shí)總結(jié)

更新時(shí)間：2018年02月11日 10:50:38 作者：yanghuatang

本篇文章給大家詳細(xì)講述了python互斥鎖、加鎖、同步機(jī)制、異步通信相關(guān)知識(shí)點(diǎn)，對(duì)此有興趣的朋友收藏下。

某個(gè)線(xiàn)程要共享數(shù)據(jù)時(shí)，先將其鎖定，此時(shí)資源的狀態(tài)為“鎖定”，其他線(xiàn)程不能更改；直到該線(xiàn)程釋放資源，將資源的狀態(tài)變成“非鎖定”，其他的線(xiàn)程才能再次鎖定該資源?；コ怄i保證了每次只有一個(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---- 
'''

您可能感興趣的文章: