python 多线程（十三-5）

客官°小女子只卖身不卖艺 2023-10-05 20:20 11阅读 0赞

**同步**：做某件事需要15秒完成，我等他完成之后，再继续后面的工作。（先唱歌完成，再可以跳舞）

**异步**：做某件事需要15秒。在这15秒之内，我可以做其他的事情。（唱歌的同时我可以跳舞）

**互斥锁**：简单理解是上一把锁. 如果没有执行完毕, 就不会被解锁。

#### 为何使用互斥锁？ ####

原因：当多个线程几乎同时修改某一个共享数据的时候, 需要进行同步控制。这样能够保证多个线程安全访问竞争资源！

import threading
    import time
    
    lock=threading.Lock() #创建一个互斥锁对象，锁住代码，执行期间不会被强制切换
    #上锁
    lock.acquire()
    #执行
    a=100+50
    #解锁:表示可以进行切换
    lock.release()

**案例：**

# 全局资源，全局变量
    _num = 0
    
    def threadA(a):
        global _num
        '''子线程A执行部分'''
        for i in range(a):
            # 上锁
            lock_.acquire()
            _num += 1  # 期间切换，发生问题
            # 解锁
            lock_.release()
        print(f'多线程中,threadA函数里面，_num的值:{_num}')
    
    
    def threadB(a):
        global _num
        '''子线程A执行部分'''
        for i in range(a):
            # 上锁
            lock_.acquire()
            _num += 1
            # 解锁
            lock_.release()
        print(f'多线程中,threadB函数里面，_num的值:{_num}')
    
    
    # 创建一个互斥锁对象
    lock_ = threading.Lock()
    
    def run():
        # count=10000
        count = 1000000
        # 创建子线程A
        t1 = threading.Thread(target=threadA, args=(count,))
        # 创建子线程B
        t2 = threading.Thread(target=threadB, args=(count,))
        t1.start()
        t2.start()
    
    # 入口
    if __name__ == '__main__':
        run()
        time.sleep(3)
        print(f'最终_num的值:{_num}')

![20210224174842980.png][]

注意

互斥锁：锁住的部分越少越好，锁住了之后就不会进行任务切换.

[20210224174842980.png]: https://img-blog.csdnimg.cn/20210224174842980.png