Python线程安全和互斥锁

清疚 2022-12-28 04:14 246阅读 0赞

# 在没有互斥锁的情况下，下面的代码结果 #

from threading import Thread, Lock
    import time
    
    global_num = 0
    
    
    def test1():
        global global_num 
        for i in range(10000000):
            global_num += 1
    
        print("---test1---g_num=%d" % global_num )
    
    
    def test2():
        global global_num 
        for i in range(10000000):
            global_num += 1
    
        print("---test2---g_num=%d" % global_num )
    
    p1 = Thread(target=test1)
    p1.start()
    
    p2 = Thread(target=test2)
    p2.start()
    
    print("---curr_g_num=%d---" % global_num )

结果：

---curr_g_num=284384---
    ---test1---g_num=12211240
    ---test2---g_num=12408762

由于没有线程安全，在两个线程中，在操作+1的操作时，比如目前g\_num=10，此时test1和test2同时拿到g\_num=10，然后都进行+1操作，我们期望结果是12，但是由于都是10+1，所以结果是11.

# 加上线程安全的互斥锁后 #

from threading import Thread, Lock
    
    global_num = 0
    
    
    def test1():
        global global_num 
        for i in range(10000000):
            mutex_flag = mutex.acquire(True)
            if mutex_flag:
                global_num += 1
                mutex.release()
    
        print("---test1---g_num=%d" % global_num )
    
    
    def test2():
        global global_num 
        for i in range(10000000):
            mutex_flag = mutex.acquire(True)
            if mutex_flag:
                global_num += 1
                mutex.release()
    
        print("---test2---g_num=%d" % global_num )
    
    
    mutex = Lock()
    
    p1 = Thread(target=test1)
    p1.start()
    
    p2 = Thread(target=test2)
    p2.start()
    
    print("---curr_g_num=%d---" % global_num )

结果：

---curr_g_num=51706---
    ---test1---g_num=19651883
    ---test2---g_num=20000000

既是我们希望的结果

# 备注 #

同一个进程中的多个线程是共享系统资源的，所以在没有互斥锁的情况下，共享资源中的数据在被多个线程资源操作修改时，会出现错误。所以就需要对被操作的对象加上互斥锁，保证该对象在被多个线程操作的时候，都是正确的结果