信号量限制

操作系统的信号量是个很重要的概念，在进程控制方面都有应用。比如在Windos下可以设置共享文件的最大客户端访问个数。

java.util.concurrent.Semaphore维护了当前访问自身的线程个数。提供同步机制，控制同时访问的线程个数。

Semaphore类的构造方法要求传入给定的许可数。

Semaphore类提供以下方法，控制同时运行的线程数。

 void acquire() 

          从此信号量获取一个许可，在提供一个许可前一直将线程阻塞，否则线程被中断 

 void release() 

          释放一个许可，将其返回给信号量。 

下面代码演示在缓存线程池中创建10个线程，由于信号量的限制，只能有3个线程同时运行。

代码如下：【TestSemaphore】

/**<br /> * TestSemaphore.java<br /> * 版权所有(C) 2011 cuiran2001@163.com<br /> * 创建:崔冉 2011-1-14 下午04:22:39<br /> */</p> <p>package com.cayden.thread835;</p> <p>import java.util.Date;<br /> import java.util.concurrent.ExecutorService;<br /> import java.util.concurrent.Executors;<br /> import java.util.concurrent.Semaphore;</p> <p>/**<br /> * @author 崔冉<br /> * @version 1.0.0<br /> * @desc<br /> */<br /> public class TestSemaphore {</p> <p> /**<br /> * @param args<br /> */<br /> public static void main(String[] args) {<br /> // TODO Auto-generated method stub<br /> ExecutorService exec=Executors.newCachedThreadPool();<br /> final Semaphore semp=new Semaphore(3);<br /> for(int i=0;i<10;i++){<br /> Runnable run=new Runnable()<br /> {<br /> public void run(){<br /> try{<br /> //获取许可<br /> semp.acquire();<br /> System.out.println(new Date()+"当前运行的线程是： "+Thread.currentThread().getName());<br /> Thread.sleep((long)(Math.random()*10000));<br /> //释放许可<br /> semp.release();<br /> }catch (InterruptedException e) {<br /> // TODO: handle exception</p> <p> }<br /> }<br /> };<br /> exec.execute(run);</p> <p> }<br /> exec.shutdown();<br /> }</p> <p>}<br />

运行结果如下：

Thu Jan 20 14:59:06 CST 2011当前运行的线程是： pool-1-thread-1</p> <p>Thu Jan 20 14:59:06 CST 2011当前运行的线程是： pool-1-thread-4</p> <p>Thu Jan 20 14:59:06 CST 2011当前运行的线程是： pool-1-thread-2</p> <p>Thu Jan 20 14:59:08 CST 2011当前运行的线程是： pool-1-thread-6</p> <p>Thu Jan 20 14:59:08 CST 2011当前运行的线程是： pool-1-thread-8</p> <p>Thu Jan 20 14:59:09 CST 2011当前运行的线程是： pool-1-thread-10</p> <p>Thu Jan 20 14:59:11 CST 2011当前运行的线程是： pool-1-thread-3</p> <p>Thu Jan 20 14:59:13 CST 2011当前运行的线程是： pool-1-thread-5</p> <p>Thu Jan 20 14:59:17 CST 2011当前运行的线程是： pool-1-thread-7</p> <p>Thu Jan 20 14:59:19 CST 2011当前运行的线程是： pool-1-thread-9<br />