Java多线程与并发库高级应用之信号量Semaphore

JDK1.5提供了一个计数信号量Semaphore类。Semaphore
通常用于限制可以访问某些资源（物理或逻辑的）的线程数目，并提供了同步机制。

Semaphore提供了两个构造器来创建对象：

1）Semaphore(int
permits)：创建具有给定的许可数和非公平的公平设置的Semaphore。

2）Semaphore(int permits, boolean fair)：创建具有给定的许可数和给定的公平设置的Semaphore。如果此信号量保证在争用时按先进先出的顺序授予许可，则为true，否则为false。

如果线程要运行首先要获取信号量，调用信号量的acquire()方法。当某线程执行完后要释放信号量，调用信号量的release()方法。

实现一个同时只允许3个线程并发访问的程序。

[java] view plaincopy

1. public class SemaphoreDemo {
2. public static void main(String[] args) {
3. //定义一个信号数为3的信号量


4. final Semaphore semaphore = new Semaphore(3);


5. //线程池


6. ExecutorService pool = Executors.newCachedThreadPool();
7. //创建10个线程


8. for(int i = 0; i < 10; i++){


9. Runnable target = new Runnable(){


10. @Override


11. public void run() {


12. try {


13. //获取信号量


14. semaphore.acquire();


15. } catch (InterruptedException e) {


16. e.printStackTrace();


17. }


18. System.out.println("线程-" + Thread.currentThread().getName() +


19. "-已进入，当前已有" + (3-semaphore.availablePermits()) + "个线程并发");


20. try {


21. Thread.sleep(1000);


22. } catch (InterruptedException e) {


23. // TODO Auto-generated catch block


24. e.printStackTrace();


25. }


26. System.out.println("线程-" + Thread.currentThread().getName() +


27. "-准备离开，当前已有" + (3-semaphore.availablePermits()) + "个线程并发");


28. //释放信号量


29. semaphore.release();


30. System.out.println("线程-" + Thread.currentThread().getName() +


31. "-离开，当前已有" + (3-semaphore.availablePermits()) + "个线程并发");


32. }


33. };


34. pool.execute(target);


35. }


36. pool.shutdown();


37. }
38. }

Java多线程与并发库高级应用之信号量Semaphore,码迷,mamicode.com