python标准库之多线程【threading】第4讲

MSK

内容概述
同步锁与递归锁，只允许一个线程访问公共资源

上一篇：
        主线程堵塞
下一篇：
        高级锁

当子线程启动时，全部线程一起执行，抢占CPU资源，有时如果大量线程同时访问一个函数，或者变量，就会出现问题。
比如：

1. import time
   
2. import threading
   
3. 
   
4. def addNum():
   
5.     global num #在每个线程中都获取这个全局变量
   
6.     # num-=1
   
7. 
   
8.     temp=num
   
9.     print('--get num:',num )
   
10.     #time.sleep(0.1)
    
11.     num =temp-1 #对此公共变量进行-1操作
    
12. 
    
13. 
    
14. num = 100  #设定一个共享变量
    
15. thread_list = []
    
16. for i in range(100):
    
17.     t = threading.Thread(target=addNum)
    
18.     t.start()
    
19.     thread_list.append(t)
    
20. 
    
21. for t in thread_list: #等待所有线程执行完毕
    
22.     t.join()
    
23. 
    
24. print('最终的数字是 :', num )

复制代码

我们把这个程序执行两次:
结果为：

1. 
   
2. #C:\Users\Administrator\Desktop\课件\4>python 1.py
   
3. #--get num: 100
   
4. #--get num: 99
   
5. #--get num: 98
   
6. #--get num: 97
   
7. #--get num: 96
   
8. #省略。。。
   
9. #--get num: 5
   
10. #--get num: 4
    
11. #final num: 3
    
12. 
    
13. #C:\Users\Administrator\Desktop\课件\4>python 1.py
    
14. #--get num: 100
    
15. #--get num: 99
    
16. #--get num: 98
    
17. #--get num: 97
    
18. #--get num: 96
    
19. #--get num: 95
    
20. #省略。。。
    
21. #--get num: 7
    
22. #--get num: 6
    
23. #--get num: 5
    
24. #final num: 4
    
25. 
    
26. #C:\Users\Administrator\Desktop\课件\4>

复制代码

用num -= 1则最终结果没问题，这是因为完成这个操作太快了，在线程切换时间内。用中间变量temp进行赋值时出现问题，这是因为100个线程，每一个都没有执行完就就行了切换，因此最终得到的不是0

多个线程同时操作同一个共享资源，所以导致冲突，这种情况就需要用同步锁来解决

创建锁的方法

1. #实例化一个锁对象
   
2.         lock = threading.Lock()
   
3.         #开启锁
   
4.         lock.acquire()
   
5.         #解除锁
   
6.         lock.release()

复制代码

       

锁保证了在调用lock.acquire()后，同一时间内只有“获得锁”的线程（先调用了lock.acquire()的线程）可以访问公共资源，其他线程被挂起，直到一个线程执行到lock.release()时解除锁,线程全部解放，下一个线程获得锁，访问公共资源，其他线程挂起。以此类推。

所以代码这样改就没问题了：

1. import time
   
2. import threading
   
3. 
   
4. def addNum():
   
5.     global num #在每个线程中都获取这个全局变量
   
6.     # num-=1
   
7.     lock.acquire()#加同步锁
   
8.     temp=num
   
9.     print('--get num:',num )
   
10.     #time.sleep(0.1)
    
11.     num =temp-1 #对此公共变量进行-1操作
    
12.     lock.release()#解锁
    
13. 
    
14. num = 100  #设定一个共享变量
    
15. thread_list = []
    
16. lock=threading.Lock()#创建lock对象
    
17. 
    
18. for i in range(10):
    
19.     t = threading.Thread(target=addNum)
    
20.     t.start()
    
21.     thread_list.append(t)
    
22. 
    
23. for t in thread_list:#等待所有线程执行完毕
    
24.     t.join()#所有线程执行完后主程序才能结束
    
25. 
    
26. print('最终的数字是 :', num )

复制代码

除了Lock，threading模块还提供了一种锁RLock（递归锁）
创建和使用方法差不多

1. lock = threading.Lock()
   
2. rlock = threading.RLock()
   
3. 
   
4. lock.acquire()
   
5. #do something
   
6. lock.release()
   
7. 
   
8. rlock.acquire()
   
9. #do something
   
10. rlock.release()

复制代码

Lock 与 RLock区别

游客，如果您要查看本帖隐藏内容请回复

hezhiqiu

好东西，正在研究中，学习

MSK

hezhiqiu 发表于 2017-6-7 15:10
好东西，正在研究中，学习

还会继续更新的

MSK

如果觉得有用的话可以订阅我的淘专辑，因为发帖有点散，这样学起来更方便哦
你的评分是对我最大的支持！

hezhiqiu

MSK 发表于 2017-6-7 15:15
还会继续更新的

怎么订阅啊？新人刚来，啥都不懂

MSK

hezhiqiu 发表于 2017-6-7 15:22
怎么订阅啊？新人刚来，啥都不懂

这是我的淘专辑地址：http://bbs.fishc.com/forum.php?m ... d=654&fromop=my
点击订阅即可！

hellozwh

看看

MSK

hellozwh 发表于 2017-6-27 19:32
看看

欢迎欢迎~

鱼粉斯

回帖是一种美德

tuxiaoqing

谢谢楼主分享

Brance

看看~~

ssj5127046

1

ephraimguo

我就是为了看内容回帖

油滴狼

看隐藏内容

深度

看下这两种锁的区别

顽童鹤

学习

syqlwzx

看看

L所戏

horsin

st

tianyali8

学习了，谢谢分享