信号量Semaphore的使用
允许多个线程同时访问:信号量(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个许可的信号量。
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
synchronized的功能的扩展:重入锁
重入锁 重入锁可以说是synchronized,Object.wait(),Object.notify()的一种替代品。 在JDK5的早期版本,重入锁的新能要比synchronized好很多,在JDK6后对synchronized进行可很多优化,使得他和重入锁的性能差距并不大。 重入锁使用java.util.concurrent.locks.ReentrantLock类实现,下面我么来看下重入锁的简单使用案例: import java.util.*; import java.util.concurrent.locks.ReentrantLock; public class ReenterLock implements Runnable { public static ReentrantLock lock=new ReentrantLock(); public static int i=0; @Override public void run() { // TODO Auto-generated method stub for(int j=0;j<10000000;j++) { l...
- 下一篇
基于泛型编程的序列化实现方法
写在前面 序列化是一个转储-恢复的操作过程,即支持将一个对象转储到临时缓冲或者永久文件中和恢复临时缓冲或者永久文件中的内容到一个对象中等操作,其目的是可以在不同的应用程序之间共享和传输数据,以达到跨应用程序、跨语言和跨平台的解耦,以及当应用程序在客户现场发生异常或者崩溃时可以即时保存数据结构各内容的值到文件中,并在发回给开发者时再恢复数据结构各内容的值以协助分析和定位原因。 泛型编程是一个对具有相同功能的不同类型的抽象实现过程,比如STL的源码实现,其支持在编译期由编译器自动推导具体类型并生成实现代码,同时依据具体类型的特定性质或者优化需要支持使用特化或者偏特化及模板元编程等特性进行具体实现。 Hello World #include <iostream> int main(int argc, char* argv[]) {
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
推荐阅读
最新文章
- SpringBoot2更换Tomcat为Jetty,小型站点的福音
- SpringBoot2初体验,简单认识spring boot2并且搭建基础工程
- CentOS8安装Docker,最新的服务器搭配容器使用
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- CentOS关闭SELinux安全模块
- Linux系统CentOS6、CentOS7手动修改IP地址
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS7设置SWAP分区,小内存服务器的救世主
- SpringBoot2整合Thymeleaf,官方推荐html解决方案