Java Semaphore用法
2013-10-17 09:54
344 查看
操作系统的信号量是个很重要的概念,在进程控制方面都有应用。Java 并发库 的Semaphore 可以很轻松完成信号量控制,Semaphore可以控制某个资源可被同时访问的个数,acquire()获取一个许可,如果没有就等待,而release()释放一个许可。比如在Windows下可以设置共享文件的最大客户端访问个数。
Semaphore维护了当前访问的个数,提供同步机制,控制同时访问的个数。在数据结构中链表可以保存“无限”的节点,用Semaphore可以实现有限大小的链表。另外重入锁ReentrantLock也可以实现该功能,但实现上要负责些,代码也要复杂些。
下面是模拟一个连接池,控制同一时间最多只能有50个线程访问。
Semaphore维护了当前访问的个数,提供同步机制,控制同时访问的个数。在数据结构中链表可以保存“无限”的节点,用Semaphore可以实现有限大小的链表。另外重入锁ReentrantLock也可以实现该功能,但实现上要负责些,代码也要复杂些。
下面是模拟一个连接池,控制同一时间最多只能有50个线程访问。
import java.util.UUID; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; public class TestSemaphore extends Thread { public static void main(String[] args) { int i = 0; while (i < 500) { i++; new TestSemaphore().start(); try { Thread.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } } } /** * 控制某资源同时被访问的个数的类 控制同一时间最后只能有50个访问 */ static Semaphore semaphore = new Semaphore(50); static int timeout = 500; public void run() { try { Object connec = getConnection(); System.out.println("获得一个连接" + connec); Thread.sleep(300); releaseConnection(connec); } catch (InterruptedException e) { e.printStackTrace(); } } public void releaseConnection(Object connec) { /* 释放许可 */ semaphore.release(); System.out.println("释放一个连接" + connec); } public Object getConnection() { try {/* 获取许可 */ boolean getAccquire = semaphore.tryAcquire(timeout, TimeUnit.MILLISECONDS); if (getAccquire) { return UUID.randomUUID().toString(); } } catch (InterruptedException e) { e.printStackTrace(); } throw new IllegalArgumentException("timeout"); } }
相关文章推荐
- Java Semaphore用法
- java多线程之Semaphore类基本用法
- java并发包里的semaphore的用法
- java 多线程之Semaphore互斥类的用法
- Java Semaphore用法
- java并发工具包:Semaphore的用法
- Java Semaphore用法
- JAVA Scanner 用法注意事项(scanner 使用错误:Exception in thread "main" java.util.NoSuchElementExceptionation )
- 详解Java中的时区类TimeZone的用法
- java中FIle的用法
- JAVA数组的定义及用法
- Java中文件选择框JFileChooser的用法
- poj1001 大数的幂 java的用法
- Java汉字转拼音pinyin4j用法
- Java enum的用法详解
- Java:Timer和TimerTask的用法
- Java之Semaphore
- java多线程-concurrent-Semaphore信号量
- Java中SimpleDateFormat格式化日期用法
- Java 并发专题 : Semaphore 实现 互斥 与 连接池