线程锁的使用 | 学习笔记

简介: 快速学习 线程锁的使用

开发者学堂课程【Python入门 2020年版线程锁的使用】学习笔记,与课程紧密联系,让用户快速学习知识。

课程地址:https://developer.aliyun.com/learning/course/639/detail/10468


线程锁的使用


内容介绍

一、线程安全问题怎么解决:线程锁的使用

二、线程锁的好处与问题


一、线程安全问题怎么解决

ticket=20

def  sell_ticket ():

global ticket

While True:

if ticket > 0:

time.sleep(1)

ticket -= 1

print('{}卖出一张票,还剩{}'.

format(threading.current_thread().name,ticket))

else:

print('票卖完了')

break

t1=threading.Thread(target=sell_ticketname=‘线程1)

t2=threading.Thread(target=sell_ticket,name=‘线程2)

t1.start()

t2.start()

1.怎么解决问题

time.sleep(1)放到 ticket -= 1下面就能解决-1的问题。

ticket=20

def  sell_ticket ():

global ticket

While True:

if ticket > 0:

ticket -= 1

time.sleep(1)

print('{}卖出一张票,还剩{}'.

format(threading.current_thread().name,ticket))

else:

print('票卖完了')

break

t1=threading.Thread(target=sell_ticketname=‘线程1)

t2=threading.Thread(target=sell_ticket,name=‘线程2)

t1.start()

t2.start()

票卖是卖完了,但是会出现线程打印数据不对的问题:

线程2卖出一张票,还剩18张线程1卖出一看张票,还剩18

线程2卖出一张票,还剩16张线程1卖出一张票,还剩16

线程1卖出一张票,还剩14张线程2卖出张票,还剩14

线程2卖出一张票,还剩12张线程1卖出一张票,还剩12

......

2.time.sleep(1)放到 print 下面:

ticket=20

def  sell_ticket ():

global ticket

While True:

if ticket > 0:

ticket -= 1

print('{}卖出一张票,还剩{}'.

format(threading.current_thread().name,ticket))

time.sleep(1)

else:

print('票卖完了')

break

t1=threading.Thread(target=sell_ticketname=‘线程1)

t2=threading.Thread(target=sell_ticket,name=‘线程2)

t1.start()

t2.start()

票是卖完了确实没什么问题。

但是 sleep 并不是说想要这个 sleep,只是模拟一个场景,买票如果中间有非常费时的操作,不可能买票就直接把票给你。

演示的是如果在你改这个变量之前有一些非常耗时的操作比如问你去哪查询信息之类的,这时会引发线程安全问题。

有个解决方案,就是给它加锁。

3.线程锁的使用

1)同步

当多个线程几乎同时修改某一个共享数据的时候,需要进行同步控制。同步就是协同步调,按预定的先后次序进行运行。记程同步能够保证多个钱程安全访问竞争资源,最简单的同步机制是引入互斥锁。

2)互斥锁

互斥锁为资源引入一个状态:锁定/非锁定

某个线程要更改共享数据时,先将其锁定,此时资源的状态为锁定”,其他线程不能更改;直到该线程释放资源,将资源的状态变成非锁定,其他的线程才能再次锁定该资源。

互斥锁保证了每次只有一个线程进行写入操作,从而保证了多线程情况下数据的正确性。

threading 模块中定义了 Lock 类,可以方便的处理锁定:

#创建锁

mutex = threading.Lock()

#锁定

mutex. acquire()

#释放

mutex.release()

锁的举例解释:有一个房间,AB 都能进入访问数据,A 进入访问数据的时候,有个锁,B 不能进。A 出来以后锁会释放掉,B 再操作。这样,线程就安全了。

锁必须是同一把锁。所以先创建一把全局变量的锁,用数据的时候锁上,判断是否大于0之前就要加上锁,卖一张锁就要 release,票全部卖完也要 release

ticket=20

#创建一把锁

lock=threading.Lock()

def  sell_ticket ():

global ticket

While True:

lock.acquire()   #加同步锁

if ticket > 0:

time.sleep(1)

ticket -= 1

lock.release()

print('{}卖出一张票,还剩{}'.

format(threading.current_thread().name,ticket))

else:

lock.release()

print('票卖完了')

break

t1=threading.Thread(target=sell_ticketname=‘线程1)

t2=threading.Thread(target=sell_ticket,name=‘线程2)

t1.start()

t2.start()


二、线程锁的好处与问题

加锁的好处,线程1进来,在锁释放前,线程2都不能进。加了同步锁线程就安全了,但是又会出现一个问题:

售票变慢,效率又降低了。但是这个问题不可避免。

当我们代码比较复杂时,比如前面有很多的功能,比如在 while True:与 if 之间有 print(‘呵呵呵’)、print(‘哈哈哈’)、print(‘ddd’)、print(‘ppp’)...100行都没有用到全局变量时,这100行的效率就比较高了。只需在后面两三行用到的地方加锁,除了加锁的地方其他地方效率都还是很高的。

但是只要访问 ticket 数据时都会出现线程安全问题。

如果有五个线程,一个进来之后,其他都得等着。适合的多线程确实在有的地方可以提高效率,但是线程过多时,不一定能提高效率。以前 Android app 做操作时,会有应用程序无响应,这个可以相当于多线程,如果联网一下要等10秒,你再点其他按钮的时候,操作系统已经接收到你的操作,但是它一直在处理第一个操作,时间久了就会卡死。

网络买票,车站,卖票怎么卖,不是访问所有数据,只需要访问一个数据库,比如说车次,就只要保证车次的数据是对的就行了。

比如2020.3.512:30从北京开往上海的高铁,只要保证这里面的数据是同步的就行,除非有大量的人同时访问时,才会出现问题。

加锁不仅会有效率问题,还会有死锁问题。

相关文章
|
3月前
|
编解码 数据安全/隐私保护 计算机视觉
Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头
如何使用OpenCV进行同步和异步操作来打开海康摄像头,并提供了相关的代码示例。
137 1
Opencv学习笔记(十):同步和异步(多线程)操作打开海康摄像头
|
4月前
|
安全 Java 编译器
线程安全问题和锁
本文详细介绍了线程的状态及其转换,包括新建、就绪、等待、超时等待、阻塞和终止状态,并通过示例说明了各状态的特点。接着,文章深入探讨了线程安全问题,分析了多线程环境下变量修改引发的数据异常,并通过使用 `synchronized` 关键字和 `volatile` 解决内存可见性问题。最后,文章讲解了锁的概念,包括同步代码块、同步方法以及 `Lock` 接口,并讨论了死锁现象及其产生的原因与解决方案。
105 10
线程安全问题和锁
|
4月前
|
安全 Java 调度
Java编程时多线程操作单核服务器可以不加锁吗?
Java编程时多线程操作单核服务器可以不加锁吗?
51 2
|
13天前
|
Java 关系型数据库 MySQL
【JavaEE“多线程进阶”】——各种“锁”大总结
乐/悲观锁,轻/重量级锁,自旋锁,挂起等待锁,普通互斥锁,读写锁,公不公平锁,可不可重入锁,synchronized加锁三阶段过程,锁消除,锁粗化
|
2月前
|
供应链 安全 NoSQL
PHP 互斥锁:如何确保代码的线程安全?
在多线程和高并发环境中,确保代码段互斥执行至关重要。本文介绍了 PHP 互斥锁库 `wise-locksmith`,它提供多种锁机制(如文件锁、分布式锁等),有效解决线程安全问题,特别适用于电商平台库存管理等场景。通过 Composer 安装后,开发者可以利用该库确保在高并发下数据的一致性和安全性。
41 6
|
4月前
|
存储 缓存 安全
【Java面试题汇总】多线程、JUC、锁篇(2023版)
线程和进程的区别、CAS的ABA问题、AQS、哪些地方使用了CAS、怎么保证线程安全、线程同步方式、synchronized的用法及原理、Lock、volatile、线程的六个状态、ThreadLocal、线程通信方式、创建方式、两种创建线程池的方法、线程池设置合适的线程数、线程安全的集合?ConcurrentHashMap、JUC
|
3月前
|
运维 API 计算机视觉
深度解密协程锁、信号量以及线程锁的实现原理
深度解密协程锁、信号量以及线程锁的实现原理
55 2
|
3月前
|
Java 应用服务中间件 测试技术
Java21虚拟线程:我的锁去哪儿了?
【10月更文挑战第8天】
57 0
|
3月前
FFmpeg学习笔记(二):多线程rtsp推流和ffplay拉流操作,并储存为多路avi格式的视频
这篇博客主要介绍了如何使用FFmpeg进行多线程RTSP推流和ffplay拉流操作,以及如何将视频流保存为多路AVI格式的视频文件。
405 0
|
5月前
|
数据采集 存储 安全
如何确保Python Queue的线程和进程安全性:使用锁的技巧
本文探讨了在Python爬虫技术中使用锁来保障Queue(队列)的线程和进程安全性。通过分析`queue.Queue`及`multiprocessing.Queue`的基本线程与进程安全特性,文章指出在特定场景下使用锁的重要性。文中还提供了一个综合示例,该示例利用亿牛云爬虫代理服务、多线程技术和锁机制,实现了高效且安全的网页数据采集流程。示例涵盖了代理IP、User-Agent和Cookie的设置,以及如何使用BeautifulSoup解析HTML内容并将其保存为文档。通过这种方式,不仅提高了数据采集效率,还有效避免了并发环境下的数据竞争问题。
如何确保Python Queue的线程和进程安全性:使用锁的技巧