首页 > 编程语言 > 详细

Java多线程与并发库高级应用之信号量Semaphore

时间：2014-05-01 11:33:50 阅读：431 评论：0 收藏：0 [点我收藏+]

标签：style blog class code java tar ext width strong get string

JDK1.5提供了一个计数信号量Semaphore类。Semaphore 通常用于限制可以访问某些资源（物理或逻辑的）的线程数目，并提供了同步机制。

Semaphore提供了两个构造器来创建对象：

1）Semaphore(int permits)：创建具有给定的许可数和非公平的公平设置的Semaphore。

2）Semaphore(int permits, boolean fair)：创建具有给定的许可数和给定的公平设置的Semaphore。如果此信号量保证在争用时按先进先出的顺序授予许可，则为true，否则为false。

如果线程要运行首先要获取信号量，调用信号量的acquire()方法。当某线程执行完后要释放信号量，调用信号量的release()方法。

实现一个同时只允许3个线程并发访问的程序。

[java] view plain copy

public class SemaphoreDemo {
public static void main(String[] args) {
//定义一个信号数为3的信号量
final Semaphore semaphore = new Semaphore(3);
//线程池
ExecutorService pool = Executors.newCachedThreadPool();
//创建10个线程
for(int i = 0; i < 10; i++){
Runnable target = new Runnable(){
@Override
public void run() {
try {
//获取信号量
semaphore.acquire();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程-" + Thread.currentThread().getName() +
"-已进入，当前已有" + (3-semaphore.availablePermits()) + "个线程并发");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println("线程-" + Thread.currentThread().getName() +
"-准备离开，当前已有" + (3-semaphore.availablePermits()) + "个线程并发");
//释放信号量
semaphore.release();
System.out.println("线程-" + Thread.currentThread().getName() +
"-离开，当前已有" + (3-semaphore.availablePermits()) + "个线程并发");
}
};
pool.execute(target);
}
pool.shutdown();
}
}

运行程序，看到同时只有3个线程并发执行。

Java多线程与并发库高级应用之信号量Semaphore,码迷,mamicode.com

Java多线程与并发库高级应用之信号量Semaphore

标签：style blog class code java tar ext width strong get string

原文地址：http://www.cnblogs.com/sfce/p/3701641.html

踩

(0)

赞

(0)

举报

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行

更多

友情链接

兰亭集智国之画百度统计站长统计阿里云 chrome插件新版天听网

关于我们 - 联系我们 - 留言反馈

© 2014 mamicode.com 版权所有联系我们:gaon5@hotmail.com

迷上了代码！