Python多線程操作之互斥鎖、遞歸鎖、信號量、事件實例詳解

import time,threading

x=6
def run1():
  print("run1我拿到了數(shù)據(jù):",x)
  print("我現(xiàn)在還不想操作，先睡一下")
  time.sleep(3)
  print("再看一下數(shù)據(jù)，穩(wěn)一穩(wěn)",x)

def run2():
  global x
  print("run2我拿到了數(shù)據(jù):", x)

  x=5
  print(x)

t1=threading.Thread(target=run1)
t2=threading.Thread(target=run2)

t1.start()
t2.start()
t1.join()
t2.join()

import time,threading

x=6
def run1():
  lock.acquire()
  global x
  print("run1我拿到了數(shù)據(jù),x=",x)
  print("我現(xiàn)在還不想操作，先睡一下")
  time.sleep(3)
  print("再看一下數(shù)據(jù)，穩(wěn)一穩(wěn),x=",x)
  x+=1
  print("run1操作完畢:x=",x)
  lock.release()
def run2():
  lock.acquire()
  global x
  print("run2我拿到了數(shù)據(jù):", x)
  x+=1
  print("run2操作完畢:x=",x)
  lock.release()

lock=threading.Lock()#生成一個鎖對象
t1=threading.Thread(target=run1)
t2=threading.Thread(target=run2)

t1.start()
t2.start()
start_time=time.time()
t1.join()
t2.join()
print("最終的x=",x)
print(time.time()-start_time)#3.0多說明，由于受到鎖的影響，run2要等待run1釋放lock，所以變成了串行

import threading,time

"""
A只能看得到北邊橋上有沒有人，看不到南邊橋有沒有人，
當(dāng)他看到北邊橋沒人就會過橋，等到他到橋中間才能看到南邊橋有沒有人
"""
def A():
  lockNorth.acquire()#拿到北邊橋的鎖
  print("A過橋北")
  time.sleep(3)#過橋中
  lockSorth.acquire()#企圖過到南邊橋，
  print("A過橋南")
  time.sleep(3) # 過橋中
  lockSorth.release()
  lockNorth.release()
  print("A過橋成功")

"""
B只能看得到南邊橋上有沒有人，看不到北邊橋有沒有人，
當(dāng)他看到南邊橋沒人就會過橋，等到他到橋中間才能看到北邊橋有沒有人
"""
def B():
  lockSorth.acquire() # 企圖過到南邊橋，
  print("B過橋南")
  time.sleep(3) # 過橋中
  lockNorth.acquire() # 拿到北邊橋的鎖
  print("B過橋北")
  time.sleep(3) # 過橋中
  lockNorth.release()
  lockSorth.release()
  print("B過橋成功")


lockNorth=threading.Lock()
lockSorth=threading.Lock()

tA=threading.Thread(target=A)
tB=threading.Thread(target=B)
tA.start()
tB.start()

tA.join()
tB.join()

import threading,time

"""
A只能看得到北邊橋上有沒有人，看不到南邊橋有沒有人，
當(dāng)他看到北邊橋沒人就會過橋，等到他到橋中間才能看到南邊橋有沒有人
"""
def A():
  lock.acquire()#拿到北邊橋的鎖
  print("A過橋北")
  time.sleep(3)#過橋中
  lock.acquire()#企圖過到南邊橋，
  print("A過橋南")
  time.sleep(3) # 過橋中
  lock.release()
  lock.release()
  print("A過橋成功")

"""
B只能看得到南邊橋上有沒有人，看不到北邊橋有沒有人，
當(dāng)他看到南邊橋沒人就會過橋，等到他到橋中間才能看到北邊橋有沒有人
"""
def B():
  lock.acquire() # 拿南橋鎖，
  print("B過橋南")
  time.sleep(3) # 過橋中
  lock.acquire() # 企圖拿北橋的鎖
  print("B過橋北")
  time.sleep(3) # 過橋中
  lock.release()
  lock.release()
  print("B過橋成功")


lock=threading.RLock()

tA=threading.Thread(target=A)
tB=threading.Thread(target=B)
tA.start()
tB.start()

tA.join()
tB.join()

import threading,time


def run():
  s.acquire()
  print("hello")
  time.sleep(1.5)
  s.release()

s=threading.BoundedSemaphore(3)#限制3個

threading_list=[]
for i in range(12):#創(chuàng)建12個線程
  obj=threading.Thread(target=run)
  obj.setDaemon(True) # 設(shè)置守護(hù)線程，避免干擾主線程運(yùn)行，并行等待
  obj.start()

for i in range(4):
  print("")#為了把結(jié)果分割，可以清楚看出分為了三組
  time.sleep(1.5)
#結(jié)果分為三組是因為運(yùn)行的太快了，三個線程裝入的時間差太小

import threading,time


def read():
  while True:
    if event.is_set():
      print("事件已設(shè)置，我要讀了!!!!")
      time.sleep(1)
    else:#事件未設(shè)置
      print("還沒寫好，我要等咯")
      event.wait()#那么就等著咯
      #如果等到了
      print("終于等到了！那么我又可以讀了")
      time.sleep(1)

def write():
  event.clear()#初始設(shè)空
  while True:
    time.sleep(3)#寫
    event.set()#設(shè)置事件，一旦set,那么讀者wait就有返回了，讀者可以繼續(xù)運(yùn)行了
    print("write:寫好了")
    time.sleep(2)#等人讀
    event.clear()#清除事件


event=threading.Event() #創(chuàng)建事件對象

t1=threading.Thread(target=write)
t2=threading.Thread(target=read)

t1.start()
t2.start()
t1.join()
t2.join()

"""結(jié)果顯示：讀者確實一直在等待寫者寫好"""