semaphore信号灯
2015-06-28 16:04
405 查看
public static void t2() {
ExecutorService service = Executors.newCachedThreadPool();
final Semaphore semaphore=new Semaphore(3,true);
for(int i=0;i<10;i++){
Runnable runnable=new Runnable(){
public void run(){
try {
semaphore.acquire();
System.out.println(Thread.currentThread().getName()+"进入,并发数为:"+(3-semaphore.availablePermits()));
Thread.sleep((long)(Math.random()*10000)+1000);
semaphore.release();
System.out.println(Thread.currentThread().getName()+"离开****,并发数为:"+(3-semaphore.availablePermits()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
service.execute(runnable);
}
service.shutdown();
}
ExecutorService service = Executors.newCachedThreadPool();
final Semaphore semaphore=new Semaphore(3,true);
for(int i=0;i<10;i++){
Runnable runnable=new Runnable(){
public void run(){
try {
semaphore.acquire();
System.out.println(Thread.currentThread().getName()+"进入,并发数为:"+(3-semaphore.availablePermits()));
Thread.sleep((long)(Math.random()*10000)+1000);
semaphore.release();
System.out.println(Thread.currentThread().getName()+"离开****,并发数为:"+(3-semaphore.availablePermits()));
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
service.execute(runnable);
}
service.shutdown();
}
相关文章推荐
- java对世界各个时区(TimeZone)的通用转换处理方法(转载)
- java-注解annotation
- java-模拟tomcat服务器
- java-用HttpURLConnection发送Http请求.
- java-WEB中的监听器Lisener
- Android IPC进程间通讯机制
- Android Native 绘图方法
- Android java 与 javascript互访(相互调用)的方法例子
- 介绍一款信息管理系统的开源框架---jeecg
- 聚类算法之kmeans算法java版本
- java实现 PageRank算法
- PropertyChangeListener简单理解
- 插入排序
- 冒泡排序
- 堆排序
- 快速排序
- 二叉查找树
- [原创]java局域网聊天系统