Python互斥锁如何解决多线程问题

  • 更新时间:2021-06-17 08:54:21
  • 编辑:江阳文
给网友朋友们带来一篇相关的编程文章,网友益慧瑶根据主题投稿了本篇教程内容,涉及到Python相关内容,已被929网友关注,内容中涉及的知识点可以在下方直接下载获取。

参考资料

正文内容

为学习python的程序员分享一篇技术文章,觉得有用就收藏了,把错误代码改掉了,希望大家能有所收获。

Python互斥锁如何解决多线程问题

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互斥锁解决多线程问题的介绍,希望对大家有所帮助。

相关教程

  • 分享11个Python自动化操作Excel的方法

    这篇文章主要给大家分享的是11个Python自动化操作Excel的方法,自动化办公,我相信很多人都有强烈的需求,今天我教大家如何利用Python自动化操作Excel,需要的朋友可以参考一下

    发布时间:2019-07-23

  • 聊聊Python代码中if __name__ == ‘__main__‘的作用是什么

    一个python文件通常有两种使用方法,第一是作为脚本直接执行,第二是 import 到其他的python脚本中被调用执行,这篇文章主要给大家介绍了关于Python代码中if __name__ == ‘__main__‘的作用是什么的相关资料,需要的朋友可以参考下

    发布时间:2019-07-23

用户留言