Java线程:新特点-信号量[Java编程]

因此,本人认为,这个信号量类假如能返回数目,还能知道哪些对象在等候,哪些资源可以利用,就非常完善了,仅仅拿到这些概括性的数字,对切确掌握意义不是很大.目前还没想到更好的用法.

下面是一个简单例子:

import　java.util.concurrent.ExecutorService;
import　java.util.concurrent.Executors;
import　java.util.concurrent.Semaphore;
/**
*　Java线程:新特点-信号量
*
*　@author　leizhimin
*/
public　class　Test　{
　　　　　　　　 public　static　void　main(String[]　args)　{
　　　　　　　　　　　　　　　　 MyPool　myPool　=　new　MyPool(20);
　　　　　　　　　　　　　　　　 //成立线程池
　　　　　　　　　　　　　　　　 ExecutorService　threadPool　=　Executors.newFixedThreadPool(2);
　　　　　　　　　　　　　　　　 MyThread　t1　=　new　MyThread("任务A",　myPool,　3);
　　　　　　　　　　　　　　　　 MyThread　t2　=　new　MyThread("任务B",　myPool,　12);
　　　　　　　　　　　　　　　　 MyThread　t3　=　new　MyThread("任务C",　myPool,　7);
　　　　　　　　　　　　　　　　 //在线程池中履行任务
　　　　　　　　　　　　　　　　 threadPool.execute(t1);
　　　　　　　　　　　　　　　　 threadPool.execute(t2);
　　　　　　　　　　　　　　　　 threadPool.execute(t3);
　　　　　　　　　　　　　　　　 //关闭池
　　　　　　　　　　　　　　　　 threadPool.shutdown();
　　　　　　　　 }
}
/**
*　一个池
*/
class　MyPool　{
　　　　　　　　 private　Semaphore　sp;　//池相关的信号量
　　　　　　　　 /**
　　　　　　　　　 *　池的大小,这个大小会传送给信号量
　　　　　　　　　 *
　　　　　　　　　 *　@param　size　池的大小
　　　　　　　　　 */
　　　　　　　　 MyPool(int　size)　{
　　　　　　　　　　　　　　　　 this.sp　=　new　Semaphore(size);
　　　　　　　　 }
　　　　　　　　 public　Semaphore　getSp()　{
　　　　　　　　　　　　　　　　 return　sp;
　　　　　　　　 }
　　　　　　　　 public　void　setSp(Semaphore　sp)　{
　　　　　　　　　　　　　　　　 this.sp　=　sp;
　　　　　　　　 }
}
class　MyThread　extends　Thread　{
　　　　　　　　 private　String　threadname;　//线程的名称
　　　　　　　　 private　MyPool　pool;　//自定义池
　　　　　　　　 private　int　x;　//申请信号量的大小
　　　　　　　　 MyThread(String　threadname,　MyPool　pool,　int　x)　{
　　　　　　　　　　　　　　　　 this.threadname　=　threadname;
　　　　　　　　　　　　　　　　 this.pool　=　pool;
　　　　　　　　　　　　　　　　 this.x　=　x;
　　　　　　　　 }
　　　　　　　　 public　void　run()　{
　　　　　　　　　　　　　　　　 try　{
　　　　　　　　　　　　　　　　　　　　　　　　 //此后信号量获得给定数目的答应
　　　　　　　　　　　　　　　　　　　　　　　　 pool.getSp().acquire(x);
　　　　　　　　　　　　　　　　　　　　　　　　 //todo:大概这里可以做更复杂的业务
　　　　　　　　　　　　　　　　　　　　　　　　 System.out.println(threadname　+　"成功获得了"　+　x　+　"个答应!");
　　　　　　　　　　　　　　　　 }　catch　(InterruptedException　e)　{
　　　　　　　　　　　　　　　　　　　　　　　　 e.printStackTrace();
　　　　　　　　　　　　　　　　 }　finally　{
　　　　　　　　　　　　　　　　　　　　　　　　 //释放给定数目的答应,将其返回到信号量.
　　　　　　　　　　　　　　　　　　　　　　　　 pool.getSp().release(x);
　　　　　　　　　　　　　　　　　　　　　　　　 System.out.println(threadname　+　"释放了"　+　x　+　"个答应!");
　　　　　　　　　　　　　　　　 }
　　　　　　　　 }
}

任务B成功获得了12个答应!
任务B释放了12个答应!
任务A成功获得了3个答应!
任务C成功获得了7个答应!
任务C释放了7个答应!
任务A释放了3个答应!
Process　finished　with　exit　code　0

从后果可以看出,信号量仅仅是对池资源举行监控,但不保证线程的安全,因此,在利用时刻,应当自己掌握线程的安全拜候池资源.

出处:http://lavasoft.blog.51cto.com/62575/222469