日常零碎记录之Java信号量-Semaphore

日常零碎记录，即把日常学习，工作中接触到的一些知识点或者没用过的知识记录下来的一个系列。方便自己巩固，也希望能给大家一点点有意义的资料参考。

Semaphore是Java提供的的一个计数信号量，内部维护了一定数目的许可证(内部许可证的获取和释放是在AbstractQueuedSynchronizer的基础上进行的)。可以有效的控制线程的数量，避免过多线程造成的内存消耗过大。

Semaphore在创建时，通过构造器指定Semaphore的许可证数目，每次线程一次操作，都需要先调用acquire方法获取许可证许可进行下一步的操作，每次线程执行操作完毕后，再调用release方法释放持有的许可证，让其他线程能够获取并执行自己的业务操作。

总的来说，使用Semaphore时，大体有三个步骤：

1.创建Semaphore，构造器中指定许可证数量；

2.执行线程操作前，执行acquire()方法获取许可证，如果没有，将一直阻塞等等；

3.完成业务操作后，执行release()方法释放许可证，让给其他线程获取执行；

简单点，直接上个例子

import java.util.concurrent.Semaphore;

public class SemaphoreDemo {

    private static Semaphore semaphore = new Semaphore(2);

    public static void main(String args[]) {

        SemaphoreTest();

    }

    public static void SemaphoreTest(){

        for(int i = 0; i <= 15; i++) {

                new Thread(new Runnable() {

                    @Override

                    public void run() {

                        try {

                            System.out.println(Thread.currentThread().getName()+"准备获取许可");

                            semaphore.acquire();

                            System.out.println(Thread.currentThread().getName()+"获取许可");

                            System.out.println("线程："+ Thread.currentThread().getName()+" 正在执行");

                            Thread.sleep(400);

                            semaphore.release();

                            System.out.println(Thread.currentThread().getName()+"释放许可");

                        }catch (InterruptedException e) {

                            e.printStackTrace();

                        }

                    }

                }).start();

            }

        }

    }

运行结果如下：

从截图可以看出，当线程0，1获取完许可证之后，其他的线程即进入了阻塞等待许可证的过程，只打印了 “****准备获取许可” 的字样，当线程0释放许可证后，其他线程也就成功获取到了许可证，随后进入了获取打印 “***正在执行” 的逻辑中去。

对于Semaphore的介绍，到这里也就结束了，下一篇，将会介绍下线程池的相关使用，然后再结合Semaphore，介绍下两者结合使用的用法及好处。