一、死锁与递归锁
1.1、死锁
死锁:锁的使用,包括抢锁以及释放锁,当两个人分别各自抢到一把锁,有需要对方的锁时就会造成死锁,即程序阻塞
Thread:操作线程模块
Lock:互斥锁模块
用户1抢到了A锁,接着抢到了B锁,释放了b锁,又释放了a锁,在抢了B锁,睡眠2s,
用户2抢到了a锁,接着要去抢B锁,但是B锁在1手上,而1需要A锁,就会造成两个人都拿不到锁。
1.2、递归锁
需要将两个锁指向同一个目标,即同一把锁,就不会造成死锁现象
内部有一个计数器,可以连续的加锁和释放锁:每次acquire就会加一,每次release就会减一,
只要计数器不为零,其他人就抢不到锁
from threading import Thread, Lock import time mutexA = Lock() mutexB = Lock() #mutexA = mutexB = RLock() #递归锁,将两把锁指向同一把锁 # 类只要加括号多次 产生的肯定是不同的对象 # 如果你想要实现多次加括号等到的是相同的对象 单例模式 class MyThead(Thread): def run(self): self.func1() self.func2() def func1(self): mutexA.acquire() print('%s 抢到A锁'% self.name) # 获取当前线程名 mutexB.acquire() print('%s 抢到B锁'% self.name) mutexB.release() mutexA.release() def func2(self): mutexB.acquire() print('%s 抢到B锁'% self.name) time.sleep(2) mutexA.acquire() print('%s 抢到A锁'% self.name) # 获取当前线程名 mutexA.release() mutexB.release() if __name__ == '__main__': for i in range(10): t = MyThead() t.start()
二、信号量:Semaphore模块
信号量在并发编程中指的是锁,即可以多个对象同时进行加锁
使用sm = Semaphore(n),填写的数量为可以有几个对象加锁
from threading import Thread, Semaphore import time import random """ 利用random模块实现打印随机验证码(搜狗的一道笔试题) """ sm = Semaphore(5) # 括号内写数字 写几就表示开设几个坑位 def task(name): sm.acquire() print('%s 正在蹲坑'% name) time.sleep(random.randint(1, 5)) sm.release() if __name__ == '__main__': for i in range(20): t = Thread(target=task, args=('伞兵%s号'%i, )) t.start()
三、Event事件
Event模块:一些线程需要等待另一个线程执行完了之后才能执行
event = Event()
event.set()通知event.wait()可以执行了
from threading import Thread, Event import time event = Event() # 造了一个红绿灯 def light(): print('红灯亮着的') time.sleep(3) print('绿灯亮了') # 告诉等待红灯的人可以走了 event.set() def car(name): print('%s 车正在灯红灯'%name) event.wait() # 等待别人给你发信号 print('%s 车加油门飙车走了'%name) if __name__ == '__main__': t = Thread(target=light) t.start() for i in range(20): t = Thread(target=car, args=('%s'%i, )) t.start()
四、线程q
4.1、进程下为什么使用队列
线程的资源是共享的,队列 = 管道 + 锁
所以队列使用来保护数据的安全
4.2、队列q,先进先出 Queue()
q = queue.Queue(3) q.put(1) 加入 q.get() 输出 q.get_nowait() q.get(timeout=3) 等待3秒后执行 q.full() 判断队列中是否饱和 q.empty() 判断队列中是否为空
4.3、堆栈q,先进后出 LifoQueue()
# q = queue.LifoQueue(3) # last in first out # q.put(1) # q.put(2) # q.put(3) # print(q.get()) # 3
4.4、优先级q PriorityQueue(n)
n代表可以入队的数量,入队时需要填元组,元组内第一个数字为优先级,第二个位置为内容,优先级的数字越低,级别越高
q = queue.PriorityQueue(4) q.put((10, '111')) q.put((100, '222')) q.put((0, '333')) q.put((-5, '444')) print(q.get()) # (-5, '444') # put括号内放一个元祖 第一个放数字表示优先级 # 需要注意的是 数字越小优先级越高!!!