importjava.util.ArrayList;
importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.Executors;
importjava.util.concurrent.Semaphore;
importjava.util.concurrent.locks.Lock;
importjava.util.concurrent.locks.ReentrantLock;
/**
*Java5.0里新增加了4个协调线程间进程的同步装置,它们分别是:Semaphore,CountDownLatch,CyclicBarrier和Exchanger
*Semaphore可以控制运行线程的个数
*Semaphore是一个用来管理资源池的工具,可以看成是个通行证,线程要想从资源池拿到资源必须先拿到通行证,如果线程暂时拿不到通告证,线程就会被阻断,进入等待状态.
*/
/**
*使用Semaphore的关键技术点如下:
*1.在构造Semaphore对象时,必须提供通行证的数目,如"newSemaphore(3)"将创建一个具有3个通行证的Semaphore对象,一旦该对象被创建,其通行证数量是不能改变的.
*2.Semaphore的acquire方法取得一个通行证,如果通行证已经发完了,当前线程将进入等待状态,直到有其他线程释放了通行证.
*3.Semaphore的release方法释放了资源池.
*/
publicclassSemaphoreTest {
/**
*模拟资源池的类
*只为池发放2个通行证,即同时只允许2个线程获得池中的资源
*/
publicstaticclassPool{
ArrayList<String>pool=null;//保存资源池中的资源
Semaphorepass=null;//通行证
Locklock=newReentrantLock();
publicPool(intsize){
//初始化资源池
pool=newArrayList<String>();
for(inti = 0; i < size;
i++){
pool.add("Resource "+ i);
}
//发送2个通行证
pass=newSemaphore(2);
}
publicString get()throwsInterruptedException{
//获取通行证,只有得到通行证后才能得到资源
System.out.println("Try to get a pass...");
pass.acquire();
System.out.println("Got a pass");
returngetResource();
}
privateString getResource(){
lock.lock();
String result =pool.remove(0);
System.out.println("资源"+
result +"被取走");
lock.unlock();
returnresult;
}
publicvoidput(String resource){
//归还通行证,并那还资源
System.out.println("Released a pass");
pass.release();
releaseResource(resource);
}
privatevoidreleaseResource(String
resource){
lock.lock();
System.out.println("资源"+
resource +"被归还");
pool.add(resource);
lock.unlock();
}
}
publicstaticvoidtestPool(){
//准备10个资源的资源池
finalPool aPool =newPool(10);
Runnable worker =newRunnable(){
@Override
publicvoidrun() {
String resource =null;
try{
resource = aPool.get();//取得resource
//用resource做工作
System.out.println("I finished on "+
resource);
Thread.sleep(500);
System.out.println("I finished on "+
resource);
}catch(InterruptedException ex){
}
aPool.put(resource);
}
};
//启动5个任务
ExecutorService service = Executors.newCachedThreadPool();
for(inti = 0; i<5; i++){
service.submit(worker);
}
service.shutdown();
}
publicstaticvoidmain(String...
args){
SemaphoreTest.testPool();
}
}
分享到:
相关推荐
Symantec Ghost 11.5.1的32位与64位版本,包含Ghostexp、GhostSrv
ghost32 11.5.1
PowerBuilder 11.5.1 4001 破解 覆盖到 \Shared\PowerBuilder 目录下 把本地日期改成一个月之后 如果还能打开pb就说明已经破解
ghost32_11.5.1克隆工具最新版的哦
PowerBuilder 11.5.1 Build 5097 的补丁, 文檔名PBSHR115.DLL, 解開後, 直接取待系統裏的文檔
cuda 11.5.1,需要的朋友可以下载一下,百度云下载
pb11.5.1-5097破解补丁:::绝对5097版的文件,不是其它版本的改过来的破解文件
纯净的win8PE,只有75M,只带一个ghost11.5.1, iso格式,可以启动虚拟机,给win10做镜像蛮方便的。 另外别追求DOS版的Ghost了,DOS版要认NTFS格式都是需要额外的驱动,未见得比PE下的32位Ghost稳定到哪里
ghost11.5.1的DOS版, ghost11.5.1.img制作启动盘的可以添加工具
win7 2008 r2 64位下的ghost,支持分区对齐?不知道啥叫对齐?晕
SQLyog 是一个快速而简洁的图形化管理MYSQL数据库的工具,它能够在任何地点有效地管理你的数据库,由业界著名的Webyog公司出品,可以快速直观地让您从世界的任何角落通过网络来维护远端的MySQL数据库。
umlet_11.5.1.zip
其他版本GHOST ,ssd分区对不齐,试试这个吧
禅道docker镜像,开源版本11.5.1
gdisk_11.5.1分区工具 最新版哦
DotNetBar11.5.1 最新破解 独家发布哦
metamask-chrome-11.5.1.zip
mysql操作实用工具,方便 mysql操作实用工具,方便 mysql操作实用工具,方便 你能简单并快速地在各种数据库系统间传输数据,或传输一份指定 SQL 格式及编码的纯文本文件。这可以简化从一台服务器迁移数据到另一台...
Powerbuilder 11.5.1 - Patch (4897) PBSHR115.DLL PBSYS115.DLL