Demo:下订单
from threading import Thread
from time import sleep
store= {
'inventory' : 100
}
# 定义一个函数,作为新线程执行的入口函数
def deposit(theadidx,orderNum):
balance = store['inventory']
# 执行减少库存操作,耗费了0.1秒
sleep(0.1)
store['inventory'] = balance - orderNum
print(f'子线程 {theadidx} 结束')
theadlist = []
for idx in range(10):
thread = Thread(target = deposit,
args = (idx,1)
)
thread.start()
# 把线程对象都存储到 threadlist中
theadlist.append(thread)
for thread in theadlist:
thread.join()
print('主线程结束')
print(f'最后我们的库存为 {store["inventory"]}')
'''
子线程 6 结束
子线程 1 结束
子线程 7 结束
子线程 0 结束
子线程 8 结束
子线程 9 结束
子线程 5 结束
子线程 4 结束
子线程 3 结束
子线程 2 结束
主线程结束
最后我们的库存为 99
Process finished with exit code 0
'''
当十个用户下完订单后,对应的库存没有从100-10=90,而是变成了99
实际减少数量和库存应减对不上
会导致每一个线程组都刷新一次余额,所有的线程没有累计起来数据共享库存数
所以需要在线程执行前,将原始数据锁起来,执行线程内容,结束后释放
使用acquire()方法上锁
使用release()方法解锁
修改后的Demo:
from threading import Thread, Lock
from time import sleep
store = {
'inventory': 100
}
sk = Lock()
# 定义一个函数,作为新线程执行的入口函数
def deposit(theadidx, orderNum):
sk.acquire() # 上锁 解库存
balance = store['inventory']
# 执行减少库存操作,耗费了0.1秒
sleep(0.1)
store['inventory'] = balance - orderNum
print(f'子线程 {theadidx} 结束')
sk.release() # 解锁
theadlist = []
for idx in range(10):
thread = Thread(target=deposit,
args=(idx, 1)
)
thread.start()
# 把线程对象都存储到 threadlist中
theadlist.append(thread)
for thread in theadlist:
thread.join()
print('主线程结束')
print(f'最后我们的库存为 {store["inventory"]}')
"""
子线程 0 结束
子线程 1 结束
子线程 2 结束
子线程 3 结束
子线程 4 结束
子线程 5 结束
子线程 6 结束
子线程 7 结束
子线程 8 结束
子线程 9 结束
主线程结束
最后我们的库存为 90
Process finished with exit code 0
"""
写在最后
线程上锁的好处:
确保了某个方法/类方法(这里为deposit方法)只能由一个线程从头到尾完整地执行
坏处:
注意:
原文地址:https://blog.csdn.net/weixin_48120964/article/details/134656821
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_38858.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。