死锁的解决办法!!!
程序员文章站
2022-05-24 13:15:50
...
首先什么是死锁呢?
- 在线程间共享多个资源的时候,如果两个线程分别占有一部分资源并且同时等待对方的资源,就会造成死锁。
- 产生死锁的四个必要条件:
①互斥条件:一个资源只能被一个进程使用;
②请求与保持条件:一个进程因请求资源而阻塞时,对方已获得的资源不释放。
③不剥夺条件:进程已获得的资源,在未使用完之前,不能强行剥夺。
④循环等待条件:若干进程之间形成一种头尾相接的循环等待资源关系。
例如:
from threading import Thread,Lock
import time
lock1=Lock()
lock2=Lock()
def work1():
lock1.acquire()
time.sleep(1)
print('one')
lock2.acquire()#等待lock2解锁
print('one--')
lock1.release()
lock2.release()
def work2():
lock2.acquire()
print('two')
lock1.acquire() #等待lock1解锁
print('two--')
lock2.release()
lock1.release()
if __name__ == '__main__':
t1=Thread(target=work1)
t2=Thread(target=work2)
t1.start()
t2.start()
#==========================
运行结果: (然后一直等待)
two
one
解决办法:
给等待加上时间 等待多长时间 不能锁定 就直接跳过 timeout=等待时间s
代码:
from threading import Thread,Lock
import time
lock1=Lock()
lock2=Lock()
def work1():
lock1.acquire()
time.sleep(1)
print('one')
lock2.acquire(timeout=2) #等待两秒钟如果锁不上 就跳过
print('one--')
lock1.release()
# lock2.release()
def work2():
lock2.acquire()
print('two')
lock1.acquire(timeout=2) #等待两秒钟 如果锁不上就跳过
print('two--')
lock2.release()
# lock1.release()
if __name__ == '__main__':
t1=Thread(target=work1)
t2=Thread(target=work2)
t1.start()
t2.start()
运行结果:(程序正常结束)
two
one
two--
one--
last:大家在平时写代码中一定要尽量避免死锁(推荐可以下去研究一下银行家算法 对避免死锁有很大帮助)
您的支持就是我前进的动力点个赞再走吧!!!