说明
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互斥锁解决多线程问题的介绍，希望对大家有所帮助。更多Python学习指路：python基础教程
本文教程操作环境：windows7系统、Python 3.9.1，DELL G3电脑。
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/3368/viewspace-2829814/ ，如需转载，请注明出处，否则将追究法律责任。
上一篇：
mysql如何使用filesort排序
下一篇：
干货|代理IP对爬虫的影响
请登录后发表评论
登录
全部评论
