博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
java多线程-Semaphore信号量使用
阅读量:6171 次
发布时间:2019-06-21

本文共 2004 字,大约阅读时间需要 6 分钟。

  • 介绍

  信号量(Semaphore),有时被称为信号灯,是在多线程环境下使用的一种设施, 它负责协调各个线程, 以保证它们能够正确、合理的使用公共资源。

  • 概念

  Semaphore分为单值和多值两种,前者只能被一个线程获得,后者可以被若干个线程获得。

  Semaphore当前在多线程环境下被扩放使用,操作系统的信号量是个很重要的概念,在进程控制方面都有应用。Java并发库Semaphore 可以很轻松完成信号量控制,Semaphore可以控制某个资源可被同时访问的个数,通过 acquire() 获取一个许可,如果没有就等待,而 release() 释放一个许可。比如在Windows下可以设置共享文件的最大客户端访问个数。

  单个信号量的Semaphore对象可以实现互斥锁的功能,并且可以是由一个线程获得了“锁”,再由另一个线程释放“锁”,这可应用于死锁恢复的一些场合。

  • 实例

  现在有一个三个信号灯,启动10个线程分别获取信号灯,当信号灯被占用时,其他线程只能等待,当信号灯被释放则等待线程获取信号灯。

  

1 public class SemaphoreTest { 2     public static void main(String[] args) { 3         ExecutorService pool =  Executors.newCachedThreadPool(); 4         final Semaphore semaphore = new Semaphore(3,true); 5          6         for (int i = 0; i < 10; i++) { 7             Runnable runnable = new Runnable() { 8                 @Override 9                 public void run() {10                     try {11                         semaphore.acquire();//获取信号灯许可12                     } catch (InterruptedException e) {13                         // TODO Auto-generated catch block14                         e.printStackTrace();15                     }16                     System.out.println("Thread "+Thread.currentThread().getName()+" 进入" +"当前系统的并发数是:"+(3-semaphore.availablePermits()));17                     try {18                         Thread.sleep(new Random().nextInt(1000));19                     } catch (InterruptedException e) {20                         // TODO Auto-generated catch block21                         e.printStackTrace();22                     }23                     System.out.println("Thread "+Thread.currentThread().getName()+" 即将离开");24                     semaphore.release();//释放信号灯25                     System.out.println("Thread "+Thread.currentThread().getName()+" 已经离开,当前系统的并发数是:"+(3-semaphore.availablePermits()));26                 }27             };28             pool.execute(runnable);29         30         }31     }32 }

  另外需要注意的一点是,信号灯可以由一个线程使用,然后由另一个线程来进行释放,而锁只能由同一个线程启动和释放,不然就好发生死锁,这一点需要格外注意。

转载地址:http://xvtba.baihongyu.com/

你可能感兴趣的文章
impdp 常见问题 10g/11g/12c 问题解决 ERIKXUE
查看>>
2013年1月工作小结 -- 上线后的懈怠
查看>>
敏捷宣言
查看>>
php Yii: 出现undefined offset 或者 undefined index解决方案
查看>>
Bash编程入门
查看>>
org.tinygroup.binarytree-二叉树
查看>>
5.6-全栈Java笔记:内部类的四种实现方式
查看>>
Linux微职位学习笔记-终端
查看>>
自己写了一个友盟推送的util
查看>>
Mapreduce 扫描hbase表建立solr索引
查看>>
RHEL 5.8 yum本地源
查看>>
Teams 新功能更新【五月底】Busy on Busy 忙线音
查看>>
orzdba安装与使用
查看>>
二叉搜索树的插入叶子结点的递归实现方法
查看>>
通过nginx配置不同二级域名代理多个系统
查看>>
linux基础篇-23,文件系统管理
查看>>
keepalived+nginx高可用配置
查看>>
node.js爬虫爬取电影天堂,实现电视剧批量下载。
查看>>
Ubuntu 18.04.1 LTS下部署FastDFS 5.11+Nginx 1.14.0
查看>>
PHP 运行方式(PHP SAPI介绍)
查看>>