递归锁
from threading import Thread,RLock
import timemutexA=mutexB=RLock()
#一個線程拿到鎖,counter加1,該線程內又碰到加鎖的情況,則counter繼續加1,
#這期間所有其他線程都只能等待,等待該線程釋放所有鎖,即counter遞減到0為止class MyThread(Thread):def run(self):self.func1()self.func2()def func1(self):mutexA.acquire()print('\033[41m%s 拿到A鎖\033[0m' %self.name)mutexB.acquire()print('\033[42m%s 拿到B鎖\033[0m' %self.name)mutexB.release()mutexA.release()def func2(self):mutexB.acquire()print('\033[43m%s 拿到B鎖\033[0m' %self.name)time.sleep(2)mutexA.acquire()print('\033[44m%s 拿到A鎖\033[0m' %self.name)mutexA.release()mutexB.release()if __name__ == '__main__':for i in range(10):t=MyThread()t.start()
#一個線程拿到鎖,counter加1,該線程內又碰到加鎖的情況,則counter繼續加1,
#這期間所有其他線程都只能等待,等待該線程釋放所有鎖,即counter遞減到0為止class MyThread(Thread):def run(self):self.func1()self.func2()def func1(self):mutexA.acquire()print('\033[41m%s 拿到A鎖\033[0m' %self.name)mutexB.acquire()print('\033[42m%s 拿到B鎖\033[0m' %self.name)mutexB.release()mutexA.release()def func2(self):mutexB.acquire()print('\033[43m%s 拿到B鎖\033[0m' %self.name)time.sleep(2)mutexA.acquire()print('\033[44m%s 拿到A鎖\033[0m' %self.name)mutexA.release()mutexB.release()if __name__ == '__main__':for i in range(10):t=MyThread()t.start()
?
轉載于:https://www.cnblogs.com/yelublue/p/9123246.html
總結
- 上一篇: java计算时间差 Java问题通用解决
- 下一篇: StoryBoard解惑