死锁:指两个或两个以上的线程在执行过程中,由于竞争资源或者由于彼此通信而造成的一种阻塞的现象,若无外力作用,它们都将无法推进下去。此时称系统处于死锁状态或系统产生了死锁,这些永远在互相等待的进程称为死锁进程。
此程序的两个线程会因为互相等待对方的互斥锁而陷入等待,最后由于主线程执行完毕而结束了各个子线程,从而程序结束。
import threading
import time class MyThread1(threading.Thread):
def run(self):
#对mutexA上锁
mutexA.acquire() #mutexA上锁,延时1秒,等待另外那个线程,把mutexB上锁
print(self.name+'----do1---up----')
time.sleep(1) #此时会堵塞,因为这个mutexA已经被另外的线程抢先上锁了
mutexB.acquire()
print(self.name+'----do2---down----')
mutexB.release() #对mutexA解锁
mutexA.release() class MyThread2(threading.Thread):
def run(self):
#对mutexA上锁
mutexB.acquire() #mutexA上锁,延时1秒,等待另外那个线程,把mutexB上锁
print(self.name+'----do1---up----')
time.sleep(1) #此时会堵塞,因为这个mutexA已经被另外的线程抢先上锁了
mutexA.acquire()
print(self.name+'----do2---down----')
mutexA.release() #对mutexB解锁
mutexB.release() if __name__=='__main__':
mutexA=threading.Lock()
mutexB=threading.Lock()
t1=MyThread1()
t2=MyThread2()
t1.start()
t2.start()
避免死锁的方法:1.添加超时时间 2.各类算法