首页 > 代码库 > 11.python并发入门(part6 Semaphore信号量)

11.python并发入门(part6 Semaphore信号量)

一、什么是信号量。

信号量也是一种锁。

信号量的主要用途是用来控制线程的并发量的,BoundedSemaphore或Semaphore管理一个内置的计数器,每调用一次acquire()方法时,计数器-1,每调用一次release()方法时,内部计数器+1。

不过需要注意的是,Semaphore内部的计数器不能小于0!当它内部的计数器等于0的时候,这个线程会被锁定,进入阻塞状态,直到其他线程去调用release方法。

BoundedSemaphore与Semaphore的唯一区别在于前者将在调用release()时检查计数 器的值是否超过了计数器的初始值,如果超过了将抛出一个异常。


二、信号量使用的示例。

#!/usr/local/bin/python2.7

# -*- coding:utf-8 -*-

import threading

import time

semaphore = threading.Semaphore(5)   #设置同一次只能最多有5个线程通过。

def func():

    if semaphore.acquire():

        print threading.currentThread().getName() + "semaphore"

        time.sleep(2)

        semaphore.release()

for _ in range(20):

    t1 = threading.Thread(target=func)

    t1.start()


输出运行结果:

Thread-1semaphore

Thread-2semaphore

Thread-3semaphore

Thread-4semaphore

Thread-5semaphore


Thread-6semaphore

Thread-7semaphore

Thread-8semaphore

Thread-9semaphore

Thread-10semaphore


Thread-13semaphore

Thread-11semaphore

Thread-12semaphore

Thread-14semaphore

Thread-15semaphore


Thread-17semaphore

Thread-20semaphore

Thread-19semaphore

Thread-18semaphore

Thread-16semaphore


一次最多放行了5个线程,这个和停车位的概念有点像。


三、信号量与递归锁的区别。

个人理解~信号量和递归锁的差别是不是,在信号量中,同一把锁,多个线程可以操作同一个共享数据,在递归锁在锁被释放之前一个线程只能操作一个共享数据。



本文出自 “reBiRTH” 博客,请务必保留此出处http://suhaozhi.blog.51cto.com/7272298/1925456

11.python并发入门(part6 Semaphore信号量)