Semaphore信号量计数器。和CountDownLatch,CyclicBarrier类似,是多线程协作的工具类,相对于join,wait,notify方法使用起来简单高效。下面我们主要看看它的用法吧!
- 限流。限制线程的并发数。
比如在一个系统中同时只能保证5个用户同时在线。
如上代码所示:我们定义了20个用户同时访问系统,Semaphore参数是5,表示同时只能有5个用户可以获取凭证,其他用户必须等待直到有在线用户退出。调用semaphore.acquire()表示获取凭证,此时凭证数会减一,调用semaphore.release()表示释放凭证,凭证数会加一,如果系统中有等待的用户,操作此方法会通知等待的一个用户获取凭证成功,执行登录操作。最后打印 部分结果如下:证明系统最多能保持5个用户同时在线。
注意:上面举出的这个案例,出个思考题:线程池是否可以实现呢?
- 模拟CyclicBarrier,CountDownLatch重用!
Semaphore可以轻松实现 CountDownLatch计数器, CyclicBarrier回环屏障,还记得 CountDownLatch用法么?它是个计数器,可以帮我们统计线程执行时间,常用来测试多线程高并发执行接口效率,我们下面用 Semaphore模拟多线程主线程等待子线程执行完毕再返回。
如上代码所示:我们定义了Semaphore初始化信号量为0,默认是非公平锁,在主线程中用线程池提交2个线程,主线程调用semaphore.acquire(2)表示需要获取两个信号量,但此时初始化信号量为0,此时AQS中的state会是0-2=-2,state值小于0,所以主线程执行这句话会阻塞将其加入AQS同步队列,线程池两个线程等待2秒后会调用semaphore.release()释放2个信号量,此时AQS中的state会自增到0,会通知主线程退出等待继续往下执行。执行结果如下图所示。
有没有发现 Semaphore用法可以模拟 CountDownLatch,另外 Semaphore通过调用acquire,release方法,还可以实现CyclicBarrier功能!我们不举例了。