python线程中的semaphore信号量是什么

2023-12-20 21:18:30

python中的线程之semaphore信号量

semaphore是一个内置的计数器,每当调用acquire()时,内置计数器-1;每当调用release()时,内置计数器+1。

计数器不能小于0,当计数器为0时,acquire()将阻塞线程直到其他线程调用release()。

来看下面的代码:

import?time
import?threading
def?foo():
????time.sleep(2)???#程序休息2秒
????print("ok",time.ctime())
for?i?in?range(20):
????t1=threading.Thread(target=foo,args=())?#实例化一个线程
????t1.start()??#启动线程

执行结果:

ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017
ok?Tue?Jul?18?20:05:58?2017

可以看到,程序会在很短的时间内生成20个线程来打印一句话。

如果在主机执行IO密集型任务的时候再执行这种类型的程序时,计算机就有很大可能会宕机。

这时候就可以为这段程序添加一个计数器功能,来限制一个时间点内的线程数量。

代码如下:

import?time
import?threading
s1=threading.Semaphore(5)???#添加一个计数器
def?foo():
????s1.acquire()????#计数器获得锁
????time.sleep(2)???#程序休眠2秒
????print("ok",time.ctime())
????s1.release()????#计数器释放锁
for?i?in?range(20):
????t1=threading.Thread(target=foo,args=())?#创建线程
????t1.start()??#启动线程

执行结果:

ok?Tue?Jul?18?20:04:38?2017
ok?Tue?Jul?18?20:04:38?2017
ok?Tue?Jul?18?20:04:38?2017
ok?Tue?Jul?18?20:04:38?2017
ok?Tue?Jul?18?20:04:38?2017
ok?Tue?Jul?18?20:04:40?2017
ok?Tue?Jul?18?20:04:40?2017
ok?Tue?Jul?18?20:04:40?2017
ok?Tue?Jul?18?20:04:40?2017
ok?Tue?Jul?18?20:04:40?2017
ok?Tue?Jul?18?20:04:42?2017
ok?Tue?Jul?18?20:04:42?2017
ok?Tue?Jul?18?20:04:42?2017
ok?Tue?Jul?18?20:04:42?2017
ok?Tue?Jul?18?20:04:42?2017
ok?Tue?Jul?18?20:04:44?2017
ok?Tue?Jul?18?20:04:44?2017
ok?Tue?Jul?18?20:04:44?2017
ok?Tue?Jul?18?20:04:44?2017
ok?Tue?Jul?18?20:04:44?2017

文章来源:https://blog.csdn.net/hakesashou/article/details/135116236
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。