线程 -- 死锁

死锁

在线程间共享多个资源的时候・如果两个线程分别占有一部分资源并且同时等待对方的资源,就会造成死锁。

尽管死锁很少发生,但一旦发生就会造成应用的停止响应。下面看一个死锁的例子

避免死锁

程序设计时尽量避免(比如:银行家算法)

添加超时时间

死锁的例子:

# 死锁: 一直等待对方释放锁的情景叫做死锁

import  threading

# 创建互斥锁

lock = threading.Lock()

# 需求: 多线程同时根据下标在列表中取值,要保证同一时刻只能有一个线程去取值

def  get_value(index):

    # 上锁

    lock.acquire()

    my_list = [1,4,6]

    # 判断下标是否越界

    if  index >= len(my_list):

        print("下标越界:", index)

        return

# 根据下标取值

value = my_list[index]

print(value)

# 释放锁

lock.release()

if__name__=='__main__':

# 创建大量线程,同时执行根据下标取值的任务

    for i in range(10):

        # 每循环一次创建一个子线程

        sub_thread = threading.Thread(target=get_value, args=(i,))

        # 启动线程执行任务

        sub_thread.start()

上面程勋运行发生了死锁,原因在于 return 执行后,标志着函数结束,但是锁没有被释放,但是你又创建了10个线程,那后面的线程就会一直等待释放锁,从而造成死锁,因此正确写法如下:

# 死锁: 一直等待对方释放锁的情景叫做死锁

import  threading

# 创建互斥锁

lock = threading.Lock()

# 需求: 多线程同时根据下标在列表中取值,要保证同一时刻只能有一个线程去取值

def  get_value(index):

    # 上锁

    lock.acquire()

    my_list = [1,4,6]

    # 判断下标是否越界

    if  index >= len(my_list):

        print("下标越界:", index)

        # 取值不成功,也需要释放互斥锁,不要影响后面的线程去取值

        # 锁需要在合适的地方进行释放,防止死锁

        lock.release()

        return

# 根据下标取值

value = my_list[index]

print(value)

# 释放锁

lock.release()

if__name__=='__main__':

# 创建大量线程,同时执行根据下标取值的任务

    for i in range(10):

        # 每循环一次创建一个子线程

        sub_thread = threading.Thread(target=get_value, args=(i,))

        # 启动线程执行任务

        sub_thread.start()

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 线程概述 多线程类似于同时执行多个不同程序,多线程运行有如下优点: 使用线程可以把占据长时间的程序中的任务放到后台...
    rookieyu阅读 391评论 0 1
  • 一、死锁的定义 多线程以及多进程[https://www.jianshu.com/p/94b7c2ab84ac]改...
    Djbfifjd阅读 915评论 0 5
  • 姓名:郭金 学号:17101223407 【嵌牛导读】:之前看到一个用jstack查看死锁的例子。总结了一下:js...
    宝宝啦啦啦阅读 827评论 0 0
  • 死锁概念 所谓的死锁指的是多个线程之间因为竞争同一系统资源从而造成的一种僵局(互相等待)现象。此时若无外力作用,这...
    阮小贰阅读 2,018评论 1 5
  • 什么是死锁 1,多线程以及多进程改善了系统资源的利用率并提高了系统的处理能力。然而,并发执行也带来了新的问题--死...
    trues阅读 426评论 0 1