Semaphore信号量
一、前言
互斥锁 同时只允许一个线程更改数据,而Semaphore是同时允许一定数量的线程更改数据 ,比如厕所有3个坑,那最多只允许3个人上厕所,后面的人只能等里面有人出来了才能再进去。
二、semaphore
信号量semaphore,是一个变量,控制着对公共资源或者临界区的访问。信号量维护着一个计数器,指定可同时访问资源或者进入临界区的线程数。 每次有一个线程获得信号量时,计数器-1。若计数器为0,其他线程就停止访问信号量,直到另一个线程释放信号量。每当调用acquire()时,内置计数器-1 每当调用release()时,内置计数器+1。
# -*- coding: UTF-8 -*- import threading import time class MyThread(threading.Thread): def run(self): global num semaphore.acquire() # 获取信号锁 lock.acquire() num += 1 print('run the thread: %s\n' % self.name) print('now the number is ', num) lock.release() time.sleep(1) semaphore.release() # 释放信号锁 num = 0 lock = threading.Lock() # 最多允许5个线程同时运行 semaphore = threading.BoundedSemaphore(5) if __name__ == '__main__': for i in range(17): t = MyThread() t.start() while threading.active_count() != 1: pass else: print('--all threads done---') print(num)
注:
- 程序运行看上去是5个一组运行的,其实如果有个线程先完成了,释放了信号量,等待的线程就能获取信号量,但不超过5个。
- 多个线程同时运行,还是会有线程安全问题,所以对共享资源竞争还是要加锁
三、使用场景
- 连接池,线程池,MySQL的有连接池,同一时间有个并发,能连多少个连接。
- 我们为了保证我的socket_server,可以使用semaphore来限制同一时间内连接数。
相关推荐
starinshy 2020-11-10
神龙 2020-06-07
laityc 2019-12-15
hahalale 2019-11-30
wordmhg 2019-11-30
GeorgeTH 2019-10-29
playlinuxxx 2016-07-30
hackerlpy 2020-09-25
archimedes 2020-11-05
小菜鸟的代码世界 2020-06-17
猛禽的编程艺术 2020-06-08
jackalwb 2020-06-05
安得情怀似旧时 2020-04-20
farwang 2020-04-20
paopao00 2020-04-09
isHooky 2020-04-09
reallyr 2020-02-23
RayCongLiang 2019-12-29
pointfish 2020-01-03