11.python并发入门（part6 Semaphore信号量）

Posted 2020-09-18

一、什么是信号量。

信号量也是一种锁。

信号量的主要用途是用来控制线程的并发量的，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