概念

死锁:某一线程的锁没有及时开释导致的程序无奈持续运行上来。是指两个或两个以上的过程或线程在执行过程中,因抢夺资源而造成的一种相互期待的景象,若无外力作用,它们都将无奈推动上来。此时称零碎处于死锁状态或零碎产生了死锁,这些永远在相互期待的过程称为死锁过程。

案例

import threadingimport time# 创立互斥锁lock = threading.Lock()# 依据下标去取值, 保障同一时刻只能有一个线程去取值def get_value(index):    # 上锁    lock.acquire()    print(threading.current_thread())    my_list = [3,6,8,1]    # 判断下标开释越界    if index >= len(my_list):        print("下标越界:", index)        return    value = my_list[index]    print(value)    time.sleep(0.2)    # 开释锁    lock.release()if __name__ == '__main__':    # 模仿大量线程去执行取值操作    for i in range(30):        sub_thread = threading.Thread(target=get_value, args=(i,))        sub_thread.start()

运行后果

剖析

下面的程序中在get_value函数中,因为下标越界间接完结了这个函数,并没有执行上面的lock.release()命令,锁始终处于锁住的状态,其余线程无奈执行,程序始终在期待运行中。

解决办法:

在适合的中央开释锁

import threadingimport time# 创立互斥锁lock = threading.Lock()# 依据下标去取值, 保障同一时刻只能有一个线程去取值def get_value(index):    # 上锁    lock.acquire()    print(threading.current_thread())    my_list = [3,6,8,1]    if index >= len(my_list):        print("下标越界:", index)        # 当下标越界须要开释锁,让前面的线程还能够取值        lock.release()        return    value = my_list[index]    print(value)    time.sleep(0.2)    # 开释锁    lock.release()if __name__ == '__main__':    # 模仿大量线程去执行取值操作    for i in range(30):        sub_thread = threading.Thread(target=get_value, args=(i,))        sub_thread.start()