互斥锁：对共享数据进行锁定，保证同一时刻只能有一个线程去操作。
​        互斥锁是多个线程一起去抢，抢到锁的线程先执行，没有抢到锁的线程需要等待，等互斥锁使用完释放后，其它等待的线程再去抢这个锁。
互斥锁的使用：

1. # 创建锁
   
2. mutex = threading.Lock()
   
3. # 上锁
   
4. metex.acquire()
   
5. # 释放锁
   
6. metex.release()

复制代码

示例代码

1. import threading
   
2. 
   
3. # 定义全局变量
   
4. g_num = 0
   
5. # 创建全局互斥锁
   
6. lock = threading.Lock()
   
7. 
   
8. def sum_num1():
   
9.     # 上锁
   
10.     lock.acquire()
    
11.     global g_num
    
12.     for i in range(1000000):
    
13.         g_num += 1
    
14.     # 释放锁
    
15.     lock.release()
    
16.     print("线程１结束后的计算值sum1为：", g_num)
    
17. 
    
18. 
    
19. def sum_num2():
    
20.     # 上锁
    
21.     lock.acquire()
    
22.     global g_num
    
23.     for i in range(1000000):
    
24.         g_num += 1
    
25.     # 释放锁
    
26.     lock.release()
    
27.     print("线程2结束后的计算值sum2为：", g_num)
    
28. 
    
29. if __name__ == '__main__':
    
30.     # 创建两个线程
    
31.     first_thread = threading.Thread(target=sum_num1)
    
32.     second_thread = threading.Thread(target=sum_num2)
    
33. 
    
34.     # 启动线程
    
35.     first_thread.start()
    
36.     # 启动线程
    
37.     second_thread.start()
    
38.    
    
39. """
    
40. 执行结果：
    
41. 线程１结束后的计算值sum1为： 1000000
    
42. 线程2结束后的计算值sum2为： 2000000
    
43. """

复制代码

互斥锁：对共享数据进行锁定，保证同一时刻只能有一个线程去操作。
​        互斥锁是多个线程一起去抢，抢到锁的线程先执行，没有抢到锁的线程需要等待，等互斥锁使用完释放后，其它等待的线程再去抢这个锁。
互斥锁的使用：

1. # 创建锁
   
2. mutex = threading.Lock()
   
3. # 上锁
   
4. metex.acquire()
   
5. # 释放锁
   
6. metex.release()

复制代码

示例代码

1. import threading
   
2. 
   
3. # 定义全局变量
   
4. g_num = 0
   
5. # 创建全局互斥锁
   
6. lock = threading.Lock()
   
7. 
   
8. def sum_num1():
   
9.     # 上锁
   
10.     lock.acquire()
    
11.     global g_num
    
12.     for i in range(1000000):
    
13.         g_num += 1
    
14.     # 释放锁
    
15.     lock.release()
    
16.     print("线程１结束后的计算值sum1为：", g_num)
    
17. 
    
18. 
    
19. def sum_num2():
    
20.     # 上锁
    
21.     lock.acquire()
    
22.     global g_num
    
23.     for i in range(1000000):
    
24.         g_num += 1
    
25.     # 释放锁
    
26.     lock.release()
    
27.     print("线程2结束后的计算值sum2为：", g_num)
    
28. 
    
29. if __name__ == '__main__':
    
30.     # 创建两个线程
    
31.     first_thread = threading.Thread(target=sum_num1)
    
32.     second_thread = threading.Thread(target=sum_num2)
    
33. 
    
34.     # 启动线程
    
35.     first_thread.start()
    
36.     # 启动线程
    
37.     second_thread.start()
    
38.    
    
39. """
    
40. 执行结果：
    
41. 线程１结束后的计算值sum1为： 1000000
    
42. 线程2结束后的计算值sum2为： 2000000
    
43. """

复制代码