这篇文章给大家分享的是有关Python互斥锁怎么解决多线程问题的内容。小编觉得挺实用的,因此分享给大家做个参考,一起跟随小编过来看看吧。
1、云计算,典型应用OpenStack。2、WEB前端开发,众多大型网站均为Python开发。3.人工智能应用,基于大数据分析和深度学习而发展出来的人工智能本质上已经无法离开python。4、系统运维工程项目,自动化运维的标配就是python+Django/flask。5、金融理财分析,量化交易,金融分析。6、大数据分析。
1、说明
当多个线程几乎同时修改共享数据时,需要同步控制。
线程同步可以保证多线程安全访问竞争资源,最简单的同步机制是引入互斥锁。
互斥锁引入资源状态:锁定/非锁定。
2、实例
"""
Python 互斥锁解决多线程资源竞争问题
"""
import time
import threading
# 线程共享变量
g_num = 0
# 创建一个互斥锁
# 默认是未上锁的状态
mutex = threading.Lock()
def work1(num):
global g_num
for i in range(num):
mutex.acquire() # 上锁
g_num += 1
mutex.release() # 解锁
print("---work1---g_num=%d" % g_num)
def work2(num):
global g_num
for i in range(num):
mutex.acquire() # 上锁
g_num += 1
mutex.release() # 解锁
print("---work2---g_num=%d" % g_num)
def mutex_test():
"""互斥锁测试"""
# 创建2个线程,让他们各自对g_num加1000000次
count = 1000000
t1 = threading.Thread(target=work1, args=(count,))
t1.start()
t2 = threading.Thread(target=work2, args=(count,))
t2.start()
# 等待计算完成
# len(threading.enumerate()) = 当前程序线程的数量
# 为1说明只剩下主线程
while len(threading.enumerate()) != 1:
time.sleep(1)
print("2个线程对同一个全局变量操作之后的最终结果是:%s" % g_num)
def main():
mutex_test()
if __name__ == '__main__':
main()
感谢各位的阅读!关于“Python互斥锁怎么解决多线程问题”这篇文章就分享到这里了,希望以上内容可以对大家有一定的帮助,让大家可以学到更多知识,如果觉得文章不错,可以把它分享出去让更多的人看到吧!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://www.py.cn/jishu/jichu/29536.html