多线程互斥锁

因为多线程运行时要争夺资源，导致同事写入全局变量的时候回出现问题 所以用互斥锁可以解决这个问题

没有上锁的时候

import threading
import time


# 定义一个全局变量
g_num = 0


def test1(num):
    global g_num
    for i in range(num):
        g_num += 1
    print("------in test1 g_num=%d----" % g_num)

def test2(num):
    global g_num
    for i in range(num):
        g_num += 1
    print("------in test1 g_num=%d----" % g_num)


def main():
    t1 = threading.Thread(target=test1,args=(1000000,))
    t2 = threading.Thread(target=test2,args=(1000000,))

    t1.start()
    t2.start()

    time.sleep(2)

    print("----in main g_num=%d-----" % g_num)

结果：

------in test1 g_num=1305261----
------in test1 g_num=1285875----
----in main g_num=1285875-----

　　

如果按照预想的，结果应该是：2000000

出现原因--资源争夺

上锁后的情况

import threading
import time


# 定义一个全局变量
g_num = 0


def test1(num):
    global g_num
    # 上锁，如果之前没被上锁，那么此时上锁成功
    # 如果上锁之前已经被上锁，那么此时会堵塞在这里，知道这个所被解开为止
    mutex.acquire()
    for i in range(num):
        g_num += 1
    # 解锁
    mutex.release()
    print("------in test1 g_num=%d----" % g_num)

def test2(num):
    global g_num
    mutex.acquire()
    for i in range(num):
        g_num += 1
    mutex.release()
    print("------in test1 g_num=%d----" % g_num)


# 创建一个互斥锁 默认是打开状态
mutex = threading.Lock()


def main():
    t1 = threading.Thread(target=test1,args=(1000000,))
    t2 = threading.Thread(target=test2,args=(1000000,))

    t1.start()
    t2.start()

    # 等待两个线程执行完毕
    time.sleep(2)

    print("----in main g_num=%d-----" % g_num)

结果

------in test1 g_num=1000000----
------in test1 g_num=2000000----
----in main g_num=2000000-----

　　

test1抢先上锁，运行完毕后会解锁，然后test2接着上锁，得出结果：2000000