一、线程安全概念
1、一个进程中可以有多个线程,且线程共享所有进程中的资源
2、多个线程同时操作一个东西,可能会导致数据混乱的情况
3、线程安全是指某个函数,函数库在多线程环境中被调用时,能够正确地处理多个线程之间的共享变量,使程序正确完成
由于线程的执行随时会发生切换,造成了不可预料的结果,出现线程不安全。
二、线程安全解决方案
1、使用线程锁Lock解决线程安全问题
2、线程锁释放的两种情况:等待(IO)导致python解释器锁释放,线程执行时长达到指定的阈值0.005秒
3、Lock与RLock都是锁
1、RLock是递归锁,支持锁多次【推荐使用】
2、Lock锁多次就会出现死锁,程序会卡死
4、死锁
1、两个程序同时竞争获取同一个锁
三、Lock使用语法
import threading
lock = threading.Lock()
lock.acquire()
try:
#do something
finally:
lock.release()
lock = threading.Lock()
with lock:
#do something
四、代码演示
场景:多线程提现
1、没有线程锁提现
import time
import threading
class Demo:
def __init__(self,balance):
self.balance = balance
def withdraw(self,amount):
if self.balance >=amount:
# 等待一秒,账户余额为负数
time.sleep(1)
self.balance -= amount
print("提现成功")
print("账户余额:",self.balance)
else:
print("提现失败,余额不足")
if __name__ == '__main__':
cl = Demo(balance=1000)
th1 = threading.Thread(target=cl.withdraw,args=(600,))
th2 = threading.Thread(target=cl.withdraw,args=(600,))
th1.start()
th2.start()
输出:
提现成功
账户余额: 400
提现成功
账户余额: -200
2、有线程锁提现
import time
import threading
class Demo:
def __init__(self,balance):
self.balance = balance
self.lock = threading.Lock()
def withdraw(self,amount):
#线程锁
with self.lock:
if self.balance >=amount:
# time.sleep(1)
self.balance -= amount
print("提现成功")
print("账户余额:",self.balance)
else:
print("提现失败,余额不足")
if __name__ == '__main__':
cl = Demo(balance=1000)
th1 = threading.Thread(target=cl.withdraw,args=(600,))
th2 = threading.Thread(target=cl.withdraw,args=(600,))
th1.start()
th2.start()
欢迎来到testingpai.com!
注册 关于