python|简单探讨一下线程锁

简介: python|简单探讨一下线程锁

为什么需要线程锁


当我们访问一些特殊的数据时,需要保证该数据的原子性,比如: 文章的阅读量、文章的点赞量等。我们必须要确保这些共享数据必须是原子性的,否则的话,多线程同时访问的时候,可能会出现异常情况,什么是原子性呢?原子性是指一个操作是不可能被中途中断的,要不全部完成,要不没有完成,这么说,可能不理解,下面举个例子来说明一下原子性的重要性:


比如我们写一个程序,来模拟10个人点赞,最后输出阅读量的值,代码如下:


image.png



代码初看好像没什么问题,反正核心点就是阅读量+1,当运行就,就出现问题了,

image.png

上述代码,运行了5次,出现了5次不一样的结果。这就是出现了竞争,所以我们需要加一个锁,来确保该阅读量函数的原子性。



线程锁使用


python中的threading模块,提供的锁就只有一种,我们使用Lock定义锁,例如:

Lock = threading.Lock()


如果需要对资源进行上锁的话,使用acquire方法即可,例如:

Lock.acquire()

如果需要对资源进行解锁的话,使用release方法即可,例如:

Lock.release()

除此之外,threading模块还提供了RLock可重入锁,可重入锁的作用和普通锁一样,用于保护资源,以保证并发访问不会出现问题,但是与普通锁不同的是,可重入锁允许同一个线程在持有锁的情况下多次获取该锁而不会发生死锁。但是在持有多少次锁,也必须释放多少次锁,否则会出现问题。



案例说明线程锁


上述我们介绍了线程锁,这里将addReaderCount进行加锁和解锁的操作,代码如下:

image.png


上述代码在源代码的基础上,在最开始使用Lock定义了一个锁,而后再函数开始之前进行一个加锁acquire(),这样的话,其他函数在执行的时候,发现这个是已经锁住了的,所以会等待,等待解锁后(releas())再进行该函数,而函数又会加锁,如此往复,能够确保在同一时刻,addReaderCount函数只执行一次。


执行程序结果为:

image.png

可以发现,这次的结果阅读量的值终于符合我们的预期了。



实现一个读写锁


python中,原生是没有读写锁的,只能借助第三方来实现,这里我们可以实现一个简单的读写锁。

在写之前,我们需要先了解下读写锁的作用到底是什么?读写锁将资源拆分为读和写2种操作,读锁允许多个线程同时读取共享资源,提高并发性能。但是当需要修改共享资源的时候,只能允许一个线程修改该共享资源,并且在修改完毕前,不允许读请求,以便造成数据不一致。所以操作完毕后,开放读请求。


这里为了实验,写了一个最简单的读写锁,安全性和效率都得不到保证,若想使用读写锁,可以使用第三方的读写锁。


我们自己写的读写锁代码如下:

image.png


上述代码,我们实现了一个读写锁类RWLock,其中有4个方法,分别为:

  • writeLock:写锁
  • writeUnlock:释放写锁
  • readLock:读锁
  • readUnlock: 释放读锁

由于读锁可以同一时刻被调用,所以我们使用的变量readCount来定义的,等需要读锁的是,readCount会+1,可以一直调用下去,而如果需要写锁的时候,这里是先将写锁变量Locked定义为True,若此时再次调用读写,会让其等待,而在写锁中,会等待读锁读取完毕后(readCount为0的时候),再进行写锁的请求。写锁执行完毕后,会将Locked给重置为False


这里写一个小的调用方法来调用一下:

image.png


上述代码,在readswrites方法中,分表调用我们之前定义的读锁和写锁,代码中定义了9个线程,分别是调用了6次读,以及3次写。

效果我们来看下:

image.png


从上述结果中,我们不难发现,在没有写锁情况下,我们使用读锁,可以访问同一资源,当使用写锁后,读锁会暂停,当写锁执行完毕后,读锁才会继续批量执行。



总结


本篇文章简单探讨了一下python线程锁,并且举了一个点赞的案例,来说明某些资源/函数需要原子性操作的时候,为避免资源竞争,所以需要在使用过程中,增加一个锁,以保证其原子性,由于python原生没有读写锁,需要依赖于第三方,所以最后我们写了一个最简单的读写锁。




相关文章
|
3月前
|
安全 数据处理 开发者
Python中的多线程编程:从入门到精通
本文将深入探讨Python中的多线程编程,包括其基本原理、应用场景、实现方法以及常见问题和解决方案。通过本文的学习,读者将对Python多线程编程有一个全面的认识,能够在实际项目中灵活运用。
|
14天前
|
Java 关系型数据库 MySQL
【JavaEE“多线程进阶”】——各种“锁”大总结
乐/悲观锁,轻/重量级锁,自旋锁,挂起等待锁,普通互斥锁,读写锁,公不公平锁,可不可重入锁,synchronized加锁三阶段过程,锁消除,锁粗化
|
2月前
|
供应链 安全 NoSQL
PHP 互斥锁:如何确保代码的线程安全?
在多线程和高并发环境中,确保代码段互斥执行至关重要。本文介绍了 PHP 互斥锁库 `wise-locksmith`,它提供多种锁机制(如文件锁、分布式锁等),有效解决线程安全问题,特别适用于电商平台库存管理等场景。通过 Composer 安装后,开发者可以利用该库确保在高并发下数据的一致性和安全性。
41 6
|
2月前
|
数据采集 存储 数据处理
Python中的多线程编程及其在数据处理中的应用
本文深入探讨了Python中多线程编程的概念、原理和实现方法,并详细介绍了其在数据处理领域的应用。通过对比单线程与多线程的性能差异,展示了多线程编程在提升程序运行效率方面的显著优势。文章还提供了实际案例,帮助读者更好地理解和掌握多线程编程技术。
|
2月前
|
并行计算 数据处理 调度
Python中的并发编程:探索多线程与多进程的奥秘####
本文深入探讨了Python中并发编程的两种主要方式——多线程与多进程,通过对比分析它们的工作原理、适用场景及性能差异,揭示了在不同应用需求下如何合理选择并发模型。文章首先简述了并发编程的基本概念,随后详细阐述了Python中多线程与多进程的实现机制,包括GIL(全局解释器锁)对多线程的影响以及多进程的独立内存空间特性。最后,通过实例演示了如何在Python项目中有效利用多线程和多进程提升程序性能。 ####
|
2月前
|
Java Unix 调度
python多线程!
本文介绍了线程的基本概念、多线程技术、线程的创建与管理、线程间的通信与同步机制,以及线程池和队列模块的使用。文章详细讲解了如何使用 `_thread` 和 `threading` 模块创建和管理线程,介绍了线程锁 `Lock` 的作用和使用方法,解决了多线程环境下的数据共享问题。此外,还介绍了 `Timer` 定时器和 `ThreadPoolExecutor` 线程池的使用,最后通过一个具体的案例展示了如何使用多线程爬取电影票房数据。文章还对比了进程和线程的优缺点,并讨论了计算密集型和IO密集型任务的适用场景。
119 4
|
3月前
|
Python
Python中的多线程与多进程
本文将探讨Python中多线程和多进程的基本概念、使用场景以及实现方式。通过对比分析,我们将了解何时使用多线程或多进程更为合适,并提供一些实用的代码示例来帮助读者更好地理解这两种并发编程技术。
|
2月前
|
监控 JavaScript 前端开发
python中的线程和进程(一文带你了解)
欢迎来到瑞雨溪的博客,这里是一位热爱JavaScript和Vue的大一学生分享技术心得的地方。如果你从我的文章中有所收获,欢迎关注我,我将持续更新更多优质内容,你的支持是我前进的动力!🎉🎉🎉
31 0
|
2月前
|
数据采集 Java Python
爬取小说资源的Python实践:从单线程到多线程的效率飞跃
本文介绍了一种使用Python从笔趣阁网站爬取小说内容的方法,并通过引入多线程技术大幅提高了下载效率。文章首先概述了环境准备,包括所需安装的库,然后详细描述了爬虫程序的设计与实现过程,包括发送HTTP请求、解析HTML文档、提取章节链接及多线程下载等步骤。最后,强调了性能优化的重要性,并提醒读者遵守相关法律法规。
74 0
|
3月前
|
Java Python
python知识点100篇系列(16)-python中如何获取线程的返回值
【10月更文挑战第3天】本文介绍了两种在Python中实现多线程并获取返回值的方法。第一种是通过自定义线程类继承`Thread`类,重写`run`和`join`方法来实现;第二种则是利用`concurrent.futures`库,通过`ThreadPoolExecutor`管理线程池,简化了线程管理和结果获取的过程,推荐使用。示例代码展示了这两种方法的具体实现方式。
python知识点100篇系列(16)-python中如何获取线程的返回值