学习多线程5---Semaphore

package com.condition;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class SemaphoreTest {

	public static void main(String[] args) {
		ExecutorService threadPool = Executors.newCachedThreadPool();
		final Semaphore semaphore = new Semaphore(4);
		for(int i = 0;i < 10;i++){
			Runnable runnable = new Runnable(){

				    @Override
					public void run() {
						try {
							semaphore.acquire();
						} catch (InterruptedException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
						System.out.println("*"+Thread.currentThread().getName()
								+" is into "+semaphore.availablePermits());
						try {
							Thread.sleep((long) (Math.random()*10000));
						} catch (InterruptedException e) {
							// TODO Auto-generated catch block
							e.printStackTrace();
						}
						System.out.println("*"+Thread.currentThread().getName()
							+" is leaving ");
						semaphore.release();		
					}
			 };
			 threadPool.execute(runnable);
		}
	}

}