概念

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

案例

import threading
import 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 threading
import 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()