Semaphore_JAVA_编程开发_程序员俱乐部

class="java">import java.util.Collections;
import java.util.HashSet;
import java.util.Set;
import java.util.Random;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Semaphore;

public class TestSemaphore {
	public static void main(String [] args)
	{
		ExecutorService es=Executors.newCachedThreadPool();

		Semaphore se=new Semaphore(2,true);
		for(int i=0;i<5;i++)
		{
			es.execute(new Thread(new Person(se)));
		}
		es.shutdown();
	}
	
}
class Person implements Runnable
{
	private Semaphore sema=null;
	public Person(Semaphore sema)
	{
		this.sema=sema;
	}
	public void run()
	{
		try
		{
			String name=Thread.currentThread().getName();
			System.out.println(name+"等待进入电话亭");
			sema.acquire();
			System.out.println(name+"进入电话亭,打电话中。。。");
			Thread.sleep(new Random().nextInt(5000));			
			System.out.println(name+"出电话亭");
			sema.release();	
		}
		catch (Exception e)
		{
		}
	}

}