Java5 多线程(四)--Semaphore实现信号灯
2013-03-20 11:55
393 查看
Semaphore可以维护当前访问自身的线程个数,并提供了同步机制,使用Semaphore可以控制同时访问资源的线程数,例如,实现一个文件允许的并发访问数.
Semaphore实现的功能就类似厕所一共有5个茅坑(new Semaphore(5)),加入有10个人(10个线程)要上厕所,那么同时只能有5个人能够占用,当占用的5个人任何一个让开后(release()方法),其中等待的另外5个人中又有一个可以占用了(acquire()方法).
另外等待的5个人可以是随机获取优先机会,也可以是按照先来后到的顺序获取机会,这取决于构造方法传入的参数选项.public Semaphore(int permits, boolean fair)
单个信号量的Semaphore对象可以实现互斥锁的功能,并且可以是由一个线程获得锁,再由另外一个线程释放锁,也就是一个线程可以去释放锁,尽管他没有得到permit,这可以应用死锁恢复的一些场合.
public class SemaphoreTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final Semaphore sp = new Semaphore(3,true);
for (int i = 0; i < 10; i++) {
Runnable runnable = new Runnable() {
public void run() {
try {
sp.acquire();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "进入,当前已有" + (3 - sp.availablePermits()) + "个并发");
try {
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "即将离开");
sp.release();
// 下面代码有时候执行不准确,因为其没有和上面的代码合成原子单元
System.out.println("线程" + Thread.currentThread().getName()
+ "已离开,当前已有" + (3 - sp.availablePermits()) + "个并发");
}
};
service.execute(runnable);
}
}
转载请注明出处: http://blog.csdn.net/johnny901114/article/details/8695717
Semaphore实现的功能就类似厕所一共有5个茅坑(new Semaphore(5)),加入有10个人(10个线程)要上厕所,那么同时只能有5个人能够占用,当占用的5个人任何一个让开后(release()方法),其中等待的另外5个人中又有一个可以占用了(acquire()方法).
另外等待的5个人可以是随机获取优先机会,也可以是按照先来后到的顺序获取机会,这取决于构造方法传入的参数选项.public Semaphore(int permits, boolean fair)
单个信号量的Semaphore对象可以实现互斥锁的功能,并且可以是由一个线程获得锁,再由另外一个线程释放锁,也就是一个线程可以去释放锁,尽管他没有得到permit,这可以应用死锁恢复的一些场合.
public class SemaphoreTest {
public static void main(String[] args) {
ExecutorService service = Executors.newCachedThreadPool();
final Semaphore sp = new Semaphore(3,true);
for (int i = 0; i < 10; i++) {
Runnable runnable = new Runnable() {
public void run() {
try {
sp.acquire();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "进入,当前已有" + (3 - sp.availablePermits()) + "个并发");
try {
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName()
+ "即将离开");
sp.release();
// 下面代码有时候执行不准确,因为其没有和上面的代码合成原子单元
System.out.println("线程" + Thread.currentThread().getName()
+ "已离开,当前已有" + (3 - sp.availablePermits()) + "个并发");
}
};
service.execute(runnable);
}
}
转载请注明出处: http://blog.csdn.net/johnny901114/article/details/8695717
相关文章推荐
- Java5 多线程(四)--Semaphore实现信号灯
- Java5 多线程(四)--Semaphore实现信号灯
- 黑马程序员——Java5中的线程并发库(二)--Semaphore实现信号灯、其他同步函数、可阻塞的队列、同步集合
- JAVA-Semaphore信号灯-可实现维护自身线程访问数
- java多线程-Semaphore信号量使用 介绍 信号量(Semaphore),有时被称为信号灯,是在多线程环境下使用的一种设施, 它负责协调各个线程, 以保证它们能够正确、合理的使用公共资源
- JAVA Semaphore实现信号灯
- java中的多线程包--Semaphore 实现 互斥 与 连接池
- java 多线程 day14 Semaphore 线程信号灯
- Java—Semaphore实现信号灯
- JAVA实现多线程的两种方法,及如何使用
- Java中有两种实现多线程的方式以及两种方式之间的区别
- Java多线程——实现线程的方式以及线程的状态
- 实现 Java 多线程并发控制框架
- 【Java面试题】26 多线程有几种实现方法?同步有几种实现方法? 当一个线程进入一个对象的一个synchronized方法后,其它线程是否可进入此对象的其它方法?
- java多线程总结五:线程池的原理及实现
- JAVA 实现多线程
- Java多线程--重入锁的实现原理
- java多线程实现(thread和runnable接口两种方式以及其区别)
- Java的两种多线程实现方式
- 实现 Java 多线程并发控制框架