翼度科技»论坛 编程开发 python 查看内容

Python中threading模块 lock、Rlock的使用

6

主题

6

帖子

18

积分

新手上路

Rank: 1

积分
18
一、概述

在使用多线程的应用下,如何保证线程安全,以及线程之间的同步,或者访问共享变量等问题是十分棘手的问题,也是使用多线程下面临的问题,如果处理不好,会带来较严重的后果,使用python多线程中提供Lock 、Rlock 、Semaphore 、Event 、Condition 用来保证线程之间的同步,后者保证访问共享变量的互斥问题。

  • Lock & RLock:互斥锁,用来保证多线程访问共享变量的问题
  • Semaphore对象:Lock互斥锁的加强版,可以被多个线程同时拥有,而Lock只能被某一个线程同时拥有。
  • Event对象:它是线程间通信的方式,相当于信号,一个线程可以给另外一个线程发送信号后让其执行操作。
  • Condition对象:其可以在某些事件触发或者达到特定的条件后才处理数据
1、Lock(互斥锁)

请求锁定 — 进入锁定池等待 — — 获取锁 — 已锁定— — 释放锁
Lock(指令锁)是可用的最低级的同步指令。Lock处于锁定状态时,不被特定的线程拥有。Lock包含两种状态——锁定和非锁定,以及两个基本的方法。
可以认为Lock有一个锁定池,当线程请求锁定时,将线程至于池中,直到获得锁定后出池。池中的线程处于状态图中的同步阻塞状态。
构造方法:mylock = Threading.Lock( )
实例方法:

  • acquire([timeout]): 使线程进入同步阻塞状态,尝试获得锁定。
  • release(): 释放锁。使用前线程必须已获得锁定,否则将抛出异常。
实例一(未使用锁):
  1. import threading
  2. import time
  3. num = 0
  4. def show(arg):
  5.     global num
  6.     time.sleep(1)
  7.     num +=1
  8.     print('bb :{}'.format(num))
  9. for i in range(5):
  10.     t = threading.Thread(target=show, args=(i,))  # 注意传入参数后一定要有【,】逗号
  11.     t.start()
  12. print('main thread stop')
  13. --------------------------------------------------------------------------
  14. main thread stop
  15. bb :1
  16. bb :2
  17. bb :3bb :4
  18. bb :5
复制代码
实例二(使用锁)
  1. import threading
  2. import time
  3. num = 0
  4. lock = threading.RLock()
  5. # 调用acquire([timeout])时,线程将一直阻塞,
  6. # 直到获得锁定或者直到timeout秒后(timeout参数可选)。
  7. # 返回是否获得锁。
  8. def Func():
  9.     lock.acquire()
  10.     global num
  11.     num += 1
  12.     time.sleep(1)
  13.     print(num)
  14.     lock.release()
  15. for i in range(10):
  16.     t = threading.Thread(target=Func)
  17.     t.start()
  18. ------------------------------------------------------------------
  19. 1
  20. 2
  21. 3
  22. 4
  23. 5
  24. 6
  25. 7
  26. 8
  27. 9
  28. 10
  29. #可以看出,全局变量在在每次被调用时都要获得锁,才能操作,因此保证了共享数据的安全性
复制代码
对于Lock对象而言,如果一个线程连续两次release,使得线程死锁。所以Lock不常用,一般采用Rlock进行线程锁的设定。
  1. import threading
  2. import time
  3. class MyThread(threading.Thread):
  4.     def run(self):
  5.         global num
  6.         time.sleep(1)
  7.         if lock.acquire(1):  
  8.             num = num+1
  9.             msg = self.name+' set num to '+str(num)
  10.             print(msg)
  11.             lock.acquire()
  12.             lock.release()
  13.             lock.release()
  14. num = 0
  15. lock = threading.Lock()
  16. def test():
  17.     for i in range(5):
  18.         t = MyThread()
  19.         t.start()
  20. if __name__ == '__main__':
  21.     test()
  22. ------------------------------------------------------
  23. Thread-12 set num to 1
复制代码
2、RLock(可重入锁)

RLock(可重入锁)是一个可以被同一个线程请求多次的同步指令。RLock使用了“拥有的线程”和“递归等级”的概念,处于锁定状态时,RLock被某个线程拥有。拥有RLock的线程可以再次调用acquire(),释放锁时需要调用release()相同次数。可以认为RLock包含一个锁定池和一个初始值为0的计数器,每次成功调用 acquire()/release(),计数器将+1/-1,为0时锁处于未锁定状态。

  • 构造方法:mylock = Threading.RLock()
  • 实例方法:acquire([timeout])/release(): 跟Lock差不多。
实例解决死锁,调用相同次数的acquire和release,保证成对出现
  1. import threading
  2. rLock = threading.RLock()  #RLock对象
  3. rLock.acquire()
  4. rLock.acquire() #在同一线程内,程序不会堵塞。
  5. rLock.release()
  6. rLock.release()
  7. print(rLock.acquire())
复制代码
详细实例:
  1. import threading
  2. mylock = threading.RLock()
  3. num = 0
  4. class WorkThread(threading.Thread):
  5.     def __init__(self, name):
  6.         threading.Thread.__init__(self)
  7.         self.t_name = name
  8.     def run(self):
  9.         global num
  10.         while True:
  11.             mylock.acquire()
  12.             print('\n%s locked, number: %d' % (self.t_name, num))
  13.             if num >= 2:
  14.                 mylock.release()
  15.                 print('\n%s released, number: %d' % (self.t_name, num))
  16.                 break
  17.             num += 1
  18.             print('\n%s released, number: %d' % (self.t_name, num))
  19.             mylock.release()
  20. def test(): #Python小白学习交流群:711312441
  21.     thread1 = WorkThread('A-Worker')
  22.     thread2 = WorkThread('B-Worker')
  23.     thread1.start()
  24.     thread2.start()
  25. if __name__ == '__main__':
  26.     test()
  27. --------------------------------------------------
  28. A-Worker locked, number: 0
  29. A-Worker released, number: 1
  30. A-Worker locked, number: 1
  31. A-Worker released, number: 2
  32. A-Worker locked, number: 2
  33. A-Worker released, number: 2
  34. B-Worker locked, number: 2
  35. B-Worker released, number: 2
复制代码
来源:https://www.cnblogs.com/xxpythonxx/p/17629487.html
免责声明:由于采集信息均来自互联网,如果侵犯了您的权益,请联系我们【E-Mail:cb@itdo.tech】 我们会及时删除侵权内容,谢谢合作!

举报 回复 使用道具