1. * 目的：了解信号灯
   
2. *x信号灯的作用：
   
3. *                控制一次运行线程的数量
   
4. */
   
5. public class SemaphoreTest {
   
6. 
   
7.         public static void main(String[] args) {
   
8.                
   
9.                 ExecutorService threadPool = Executors.newCachedThreadPool();
   
10.                 final Semaphore semaphore = new Semaphore(3);   //定义一个有三个信号的Semaphore
    
11.                
    
12.                 for(int i=0;i<7;i++){
    
13.                         Runnable runnable = new Runnable(){
    
14.                                 public void run() {
    
15.                                         try {
    
16.                                                 semaphore.acquire();  //每获取一次信号灯，信号灯的数量就减一。
    
17.                                                                                                 //如果没有了信号灯，线程等待其他线程释放信号灯
    
18.                                                 //Thread.sleep(2000);
    
19.                                             System.out.println(Thread.currentThread().getName()+":正在运行,"+
    
20.                                                                                         "目前可利用的信号灯为:"+semaphore.availablePermits());
    
21.                                            Thread.sleep(4000);
    
22.                                            System.out.println(Thread.currentThread().getName()+":即将离开");
    
23.                                         }catch (InterruptedException e) {
    
24.                                                 e.printStackTrace();
    
25.                                         }finally{
    
26.                                                 semaphore.release();   //释放信号灯,信号灯的数量加一
    
27.                                         }
    
28.                                 }
    
29.                         };
    
30.                         threadPool.execute(runnable);
    
31.                 }
    
32.                 threadPool.shutdown();
    
33.         }
    
34. }
    

复制代码

1. * 目的：了解信号灯
   
2. *x信号灯的作用：
   
3. *                控制一次运行线程的数量
   
4. */
   
5. public class SemaphoreTest {
   
6. 
   
7.         public static void main(String[] args) {
   
8.                
   
9.                 ExecutorService threadPool = Executors.newCachedThreadPool();
   
10.                 final Semaphore semaphore = new Semaphore(3);   //定义一个有三个信号的Semaphore
    
11.                
    
12.                 for(int i=0;i<7;i++){
    
13.                         Runnable runnable = new Runnable(){
    
14.                                 public void run() {
    
15.                                         try {
    
16.                                                 semaphore.acquire();  //每获取一次信号灯，信号灯的数量就减一。
    
17.                                                                                                 //如果没有了信号灯，线程等待其他线程释放信号灯
    
18.                                                 //Thread.sleep(2000);
    
19.                                             System.out.println(Thread.currentThread().getName()+":正在运行,"+
    
20.                                                                                         "目前可利用的信号灯为:"+semaphore.availablePermits());
    
21.                                            Thread.sleep(4000);
    
22.                                            System.out.println(Thread.currentThread().getName()+":即将离开");
    
23.                                         }catch (InterruptedException e) {
    
24.                                                 e.printStackTrace();
    
25.                                         }finally{
    
26.                                                 semaphore.release();   //释放信号灯,信号灯的数量加一
    
27.                                         }
    
28.                                 }
    
29.                         };
    
30.                         threadPool.execute(runnable);
    
31.                 }
    
32.                 threadPool.shutdown();
    
33.         }
    
34. }
    

复制代码