java.util.concurrent之Semaphore
2015-09-22 14:59
330 查看
jdk介绍:一个计数信号量。从概念上讲,信号量维护了一个许可集。如有必要,在许可可用前会阻塞每一个
适用场景:有很多个线程,但是同一时间只允许n个线程执行,其他线程只能等待,除非获取执行许可
代码如下:
package test;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class TestSemaphore {
public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
final Semaphore semaphore = new Semaphore(2);
for (int i = 0; i < 4; i++) {
Runnable runnable = new Runnable() {
public void run() {
try {
semaphore.acquire();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName() + "获取许可,当前有" + (2 - semaphore.availablePermits()) + "个线程在执行");
try {
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName() + "执行完成,将要释放许可");
semaphore.release();
System.out.println("线程" + Thread.currentThread().getName() + "已释放许可,当前有" + (2 - semaphore.availablePermits()) + "个线程在执行");
}
};
executorService.execute(runnable);
}
executorService.shutdown();
}
}
执行结果如下:
线程pool-1-thread-2获取许可,当前有2个线程在执行
线程pool-1-thread-1获取许可,当前有2个线程在执行
线程pool-1-thread-1执行完成,将要释放许可
线程pool-1-thread-1已释放许可,当前有1个线程在执行
线程pool-1-thread-3获取许可,当前有2个线程在执行
线程pool-1-thread-2执行完成,将要释放许可
线程pool-1-thread-2已释放许可,当前有1个线程在执行
线程pool-1-thread-4获取许可,当前有2个线程在执行
线程pool-1-thread-4执行完成,将要释放许可
线程pool-1-thread-4已释放许可,当前有1个线程在执行
线程pool-1-thread-3执行完成,将要释放许可
线程pool-1-thread-3已释放许可,当前有0个线程在执行
acquire(),然后再获取该许可。每个
release()添加一个许可,从而可能释放一个正在阻塞的获取者。但是,不使用实际的许可对象,
Semaphore只对可用许可的号码进行计数,并采取相应的行动。
适用场景:有很多个线程,但是同一时间只允许n个线程执行,其他线程只能等待,除非获取执行许可
代码如下:
package test;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;
public class TestSemaphore {
public static void main(String[] args) {
ExecutorService executorService = Executors.newCachedThreadPool();
final Semaphore semaphore = new Semaphore(2);
for (int i = 0; i < 4; i++) {
Runnable runnable = new Runnable() {
public void run() {
try {
semaphore.acquire();
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName() + "获取许可,当前有" + (2 - semaphore.availablePermits()) + "个线程在执行");
try {
Thread.sleep((long) (Math.random() * 10000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程" + Thread.currentThread().getName() + "执行完成,将要释放许可");
semaphore.release();
System.out.println("线程" + Thread.currentThread().getName() + "已释放许可,当前有" + (2 - semaphore.availablePermits()) + "个线程在执行");
}
};
executorService.execute(runnable);
}
executorService.shutdown();
}
}
执行结果如下:
线程pool-1-thread-2获取许可,当前有2个线程在执行
线程pool-1-thread-1获取许可,当前有2个线程在执行
线程pool-1-thread-1执行完成,将要释放许可
线程pool-1-thread-1已释放许可,当前有1个线程在执行
线程pool-1-thread-3获取许可,当前有2个线程在执行
线程pool-1-thread-2执行完成,将要释放许可
线程pool-1-thread-2已释放许可,当前有1个线程在执行
线程pool-1-thread-4获取许可,当前有2个线程在执行
线程pool-1-thread-4执行完成,将要释放许可
线程pool-1-thread-4已释放许可,当前有1个线程在执行
线程pool-1-thread-3执行完成,将要释放许可
线程pool-1-thread-3已释放许可,当前有0个线程在执行
相关文章推荐
- Python3写爬虫(四)多线程实现数据爬取
- C#实现多线程的同步方法实例分析
- 浅谈chuck-lua中的多线程
- C#简单多线程同步和优先权用法实例
- C#多线程学习之(四)使用线程池进行多线程的自动管理
- C#多线程编程中的锁系统(三)
- C#多线程学习之(六)互斥对象用法实例
- 基于一个应用程序多线程误用的分析详解
- C#多线程学习之(三)生产者和消费者用法分析
- C#多线程学习之(一)多线程的相关概念分析
- C#多线程之Thread中Thread.IsAlive属性用法分析
- C#控制台下测试多线程的方法
- Ruby 多线程的潜力和弱点分析
- C#中WPF使用多线程调用窗体组件的方法
- C#如何对多线程、多任务管理(demo)
- C#实现多线程的Web代理服务器实例
- c#实现多线程局域网聊天系统
- PHP使用CURL实现多线程抓取网页
- 浅解关于C#多线程的介绍
- 批处理程序中的“多线程”处理代码