摘要：
信号量（Semaphore） 前面在信号量中提到的线程锁（互斥锁）只允许一个线程同时更改数据，而信号量允许一定数量的线程同时更改。每次一个线程获得信号量，直到另一个线程释放信号量，它都是在同一时间。只能允许一组线程执行import_threadingimport_time_derun（n）：
之前讲的线程锁（互斥锁） 同时只允许一个线程更改数据，而Semaphore是同时允许一定数量的线程更改数据 ，比如厕所有3个坑，那最多只允许3个人上厕所，后面的人只能等里面有人出来了才能再进去。
1、信号量
- 是一个变量，控制着对公共资源或者临界区的访问。信号量维护着一个计数器，指定可同时访问资源或者进入临界区的线程数。
- 每次有一个线程获得信号量时，计数器-1。若计数器为0，其他线程就停止访问信号量，直到另一个线程释放信号量
说白了就是在同一时间，可以只允许设定的数量的线程去执行
import threading
import time
def run(n):
semaphore.acquire() # 加信号量锁
time.sleep(5)
print("run the thread: %s
" % n)
semaphore.release() # 释放信号量锁
if __name__ == '__main__':
semaphore = threading.BoundedSemaphore(5) # 最多允许5个线程同时运行(Bounded:绑定，Semaphore：信号量)
for i in range(20):
t = threading.Thread(target=run, args=(i,))
t.start()
while threading.active_count() != 1:
pass
else:
print('----all threads done---')
上面程序的执行，会让人感觉是：分了4组，前5个同时完成，然后又5个同时进去。但是实际的效果是：这5个里面如果有3个完成，就会立刻再放3个进去。不会等5个都完成，每出来1个就放进去1个，出来几个放进去几个
2、使用场景和总结
- 连接池，线程池，MySQL的有连接池，同一时间有多少个并发，就能连多少个连接。
- 我们为了保证我的socket_server，因为python不会默认现在你启动多少个线程，但是你启动的线程越多，就会把系统拉的越慢，就会把程序拉的越慢。这里就可以搞一个我同一时间放100线程个进来，就是用semaphore
- python3.x 虽然不加锁也是正确的，但是最好还是把锁加上
日常生活中经常遇到红绿灯，我们就很好理解红绿灯的例子，就是红灯停，绿灯行。
现在生成一个线程，这个线程我让它扮演红绿灯，它每过一段时间就变成绿灯，又过一段时间变成红灯，又变成黄灯。然后再生成3-5个线程作为车。车看见红灯，它就停下来等着，如果说是绿灯，车子就走。所以就涉及到红灯这个线程，红绿灯的这个线程就跟车线程之前产生了依赖了。就是红绿灯这个线程必须在绿灯的时候才能走，在红灯的时候就立刻停下来。所以互相之前，一个线程会根据另外一个线程的状态产生一些变化。类似这种场景的实现，就是：event，即事件。
1、事件的基础内置函数
event = threading.Event() # 设置一个事件的全局变量 event.is_set()# 判断是否已经设置标志位。 event.wait() # 没有设置标志位的时候会阻塞，一遇到标志位就不会阻塞 #判断是否已经设置标志位。 event.set() # 设置标志位 ，标志位设置了，代表着绿灯，直接通行。 event.clear() # 清除标志位，标志位被清空，代表红灯，wait等待变绿灯。
2、红绿灯例子
import threading
import time
event = threading.Event() # 生成线程事件实例
def lighter():
"""
模拟红绿灯
:return:
"""
count = 0
event.set() # 先设置标志位,代表绿灯
while True:
if count > 5 and count < 10: # 改成红灯
event.clear() # 清除标志位，变成红灯
print("