信号量Semaphore的使用

简介: 允许多个线程同时访问:信号量(Semaphore)信号量为多线程协作提供了更为强大的控制方法。广义上说,信号量是对锁的扩展。无论是内部锁synchronized还是重入锁ReentrantLock,一次都只允许一个线程访问一个资源,而信号量指定多个线程访问同一个资源。

允许多个线程同时访问:信号量(Semaphore)

信号量为多线程协作提供了更为强大的控制方法。广义上说,信号量是对锁的扩展。无论是内部锁synchronized还是重入锁ReentrantLock,一次都只允许一个线程访问一个资源,而信号量指定多个线程访问同一个资源。
信号主要提供以下的构造函数。

public Semaphore(int permits);//permits 指定信号量的准入数
public Semaphore(int permits,boolean fair);//第二个参数指定是否公平

在构造信号量时,必须指定信号量的准入数,即同时能申请多少许可,若一个线程每次只申请一个许可,这就相当于指定了同时允许多少个线程能访问同一资源。
信号量的主要逻辑方法包括以下几种:

public void acquire();
public void acquireUninterruptibly();
public boolean tryAcquire();
public boolean tryAcquire(long timeout,TimeUnit unit);
public void release();

acquire()方法尝试获得一个准入的许可。若无法获得,线程会等待,直到有线程释放一个许可或者线程被中断。acquireUninterruptibly()方法和acquire()方法类似,但是不能相应中断。tryacquire()尝试获得一个许可,成功返回true失败返回false,他不会进行等待,立即返回。release()用于在线程访问资源结束后,释放一个许可,使其他线程可以进行资源访问。
下面我们使用一个例子来演示信号量的使用:

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class SemapDemo implements Runnable {

    final Semaphore semp=new Semaphore(5);

    @Override
    public void run() {
        // TODO Auto-generated method stub
        try {
            semp.acquire();
            Thread.sleep(2000);
            System.out.println(Thread.currentThread().getId()+":done!");
            semp.release();
        }catch(InterruptedException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        // TODO Auto-generated method stub
        ExecutorService exec=Executors.newFixedThreadPool(20);
        final SemapDemo demo=new SemapDemo();
        for(int i=0;i<20;i++) {
            exec.submit(demo);
        }
    }

}

可以看到程序会限制执行这段代码的线程数,观察结果可以看到每次5个线程一组,因为我们设置了允许5个许可的信号量。

相关文章
|
3月前
|
Java
JAVA并发编程系列(7)Semaphore信号量剖析
腾讯T2面试,要求在3分钟内用不超过20行代码模拟地铁安检进站过程。题目设定10个安检口,100人排队,每人安检需5秒。实际中,这种题目主要考察并发编程能力,特别是多个线程如何共享有限资源。今天我们使用信号量(Semaphore)实现,限制同时进站的人数,并通过信号量控制排队和进站流程。并详细剖析信号量核心原理和源码。
Semaphore 使用详解
本文主要对Semaphore 的相关知识点进行了介绍和讲解
123 0
|
7月前
|
数据库连接
认识 Semaphore
认识 Semaphore
54 0
|
7月前
多线程并发之Semaphore(信号量)使用详解
多线程并发之Semaphore(信号量)使用详解
2545 0
|
Java 数据库连接 API
【JUC】信号量Semaphore详解
【JUC】信号量Semaphore详解
186 0
【JUC】信号量Semaphore详解
Semaphore(信号量)介绍以及实例
Semaphore(信号量)介绍以及实例
183 0
Semaphore(信号量)介绍以及实例
并发编程之Semaphore信号量
`Semaphore` 翻译过来就是信号量, 其根本原理就是基于 `CAS` 共享锁的一种实现。举一个例子。 假设停车场只有三个车位,一开始三个车位都是空的。这时如果同时来了五辆车,看门人允许其中三辆不受阻碍的进入,然后放下车拦,剩下的车则必须在入口等待,此后来的车也都不得不在入口处等待。这时,有一辆车离开停车场,看门人得知后,打开车拦,放入一辆,如果又离开两辆,则又可以放入两辆,如此往复。
179 0
|
监控 数据库连接
呵,Semaphore ,就这?(一)
那么本篇文章我们继续来和你聊聊并发工具类的第二篇文章 --- Semaphore 。
129 0
呵,Semaphore ,就这?(一)
|
Java
呵,Semaphore ,就这?(二)
那么本篇文章我们继续来和你聊聊并发工具类的第二篇文章 --- Semaphore 。
127 0
呵,Semaphore ,就这?(二)
|
Java
Java并发编程之Semaphore信号量
Java并发编程之Semaphore信号量
156 0
Java并发编程之Semaphore信号量