一 信号量
信号量也是一把锁，可以指定信号量为5，对比互斥锁同一时间只能有一个任务抢到锁去执行，信号量同一时间可以有5个任务拿到锁去执行，如果说互斥锁是合租房屋的人去抢一个厕所，那么信号量就相当于一群路人争抢公共厕所，公共厕所所有多个坑位，这意味着同一时间可以有多个人上公共厕所，但公共厕所容纳的人数是一定的，这便是信号量的大小
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | from threading import Thread, Semaphore
import threading
import time
def func():
sm.acquire()
print('%s get sm' % threading.current_thread().getName())
time.sleep(3)
sm.release()
if __name__ == '__main__':
sm = Semaphore(5)
for i in range(23):
t = Thread(target=func)
t.start()
|
解析
| 1 2 3 4 | Semaphore管理一个内置的计数器，
每当调用acquire()时内置计数器-1
调用release()时内置计数器+1
计数器不能小于0；当计数器为0时，acquire()将阻塞线程直到其它线程调用rel()
|
二、Event
线程的一个关键特性是每个线程都是独立运行且状态不可预测。如果程序中的其它线程需要通过判断某个线程的状态来确定自己下一步的操作，这时线程同步问题就会变得非常棘手。为了解决这些问题，我们需要使用threading库中的Event对象。对象包含一个可由线程设置的信号标志，它允许线程等待某些事件的发生。在初始情况下，Event对象中的信号标志被设置为假。如果有线程等待一个Event对象，而这个Event对象的标志为假，那么这个线程将会被一直阻塞至标志为真。一个线程如果将一个Event对象的信号标志设置为真，它将唤醒所有等待这个Event对象的线程。如果一个线程等待一个已经被设置为真的Event对象，它将忽略这个事件，继续执行
| 1 2 3 4 5 | from threading import Event
Event.isSet() # 返回Event的状态值
Event.wait() # 如果event.isSet()==False将阻塞线程；
Event.set() # 设置Event的状态值为True，所有阻塞池的线程激活进入就绪状态，等待操作系统调度
Event.clear() # 恢复Event的状态值为False
|
例如：有多个工作线程尝试链接MySQL，我们想要在链接前确保MySQL服务正常才让那些工作线程去连接MySQL服务器，如果连接不成功，都会去尝试重新连接。那么
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 | from threading import Thread, Event
import threading
import time, random
def conn_mysql():
count = 1
while not event.is_set():
if count > 3:
raise TimeoutError('链接超时')
print('<%s>第%s次尝试链接' % (threading.current_thread().getName(), count))
event.wait(0.5)
count += 1
print('<%s>链接成功' % threading.current_thread().getName())
def check_mysql():
print('\033[45m[%s] 正在检查mysql\033[0m' % threading.current_thread().getName())
time.sleep(random.randint(2, 4))
event.set()
if __name__ == '__main__':
event = Event()
conn1 = Thread(target=conn_mysql)
conn2 = Thread(target=conn_mysql)
check = Thread(target=check_mysql)
conn1.start()
conn2.start()
check.start()
|
三 定时器
定时器，指定n秒后执行某操作
| 1 2 3 4 5 6 7 8 | from threading import Timer
def hello():
print('hello, world')
t = Timer(1, hello)
t.start()
|
