600字范文,内容丰富有趣,生活中的好帮手!
600字范文 > python并发编程之semaphore(信号量)_python并发编程之Semaphore(信号量)

python并发编程之semaphore(信号量)_python并发编程之Semaphore(信号量)

时间:2023-01-20 12:25:51

相关推荐

python并发编程之semaphore(信号量)_python并发编程之Semaphore(信号量)

threading模块里的Semaphore类实现了信号量对象,可用于控制获取资源的线程数量。所具有的acquire()和release()方法,可以用with语句的上下文管理器。当进入时,将调用acquire()方法,当退出时,将调用release()。

acquire(blocking=True, timeout=None):

timeout设置超时秒。如果未在时间间隔内完成,返回false;否则返回true

没有blocking返回false,否则返回true。

release():

释放一个信号量

# **coding: utf-8**

import threading

import time

def hello(n, sema):

sema.acquire()

print('调用线程{0}'.format(n))

# 信号量管理表示realse()调用数减去acquire()调用数加上去一个初始值的计数器1-5+0=-4

sema = threading.Semaphore(value=0)

workers = 5

for n in range(workers):

t = threading.Thread(target=hello, args=(n+1, sema, ))

t.start()

time.sleep(3)

print('开启线程')

sema.release() Semaphore的value参数表示内部计数器的初始值,默认值为0。信号量内部有个计数器,它的计算方式:release()调用数减去acquire()调用数加上一个初始值。例如上边给的初始值为0,release()调用1次,acquire()调用5次.计算值为-4,则acquire()方法将会阻塞到可以返回时的计数器不是负数,也就是只有第一个线程返回为0。

输出结果为:

开启线程

调用线程1 可以看到其余的4个线程并没有执行。

本内容不代表本网观点和政治立场,如有侵犯你的权益请联系我们处理。
网友评论
网友评论仅供其表达个人看法,并不表明网站立场。