一.Semaphore
Semaphore semaphore =new Semaphore(2);-----他是一个AQS的共享锁,可以允许多个线程拿到资源
1.semaphore.acquire() --------表示阻塞并获取许可
public void acquire()throws InterruptedException {
sync.acquireSharedInterruptibly(1); //调用此方法,通过传参可以看出,调用一次acquire(),获取一个公共资源
}
public final void acquireSharedInterruptibly(int arg)
throws InterruptedException {
if (Thread.interrupted()) //判断此线程是否已经中断
throw new InterruptedException();
if (tryAcquireShared(arg) <0) //tryAcquireShared(arg)方法本质调用Sync中的tryAcquireShared()方法,方法内部操作看下图解析
doAcquireSharedInterruptibly(arg);
}
线程进入后更新AQS中的资源数
线程的入队等待操作
2.semaphore.release() ----------表示释放许可(释放公共资源)
主要作用:他是一个计数信号,主要需求场景是进行 资源访问,服务限流
semaphore默认创建非公平锁
二.CountDownLatch
1.概念:
CountDownLatch这个类能够使一个线程等待其他线程完成各自的工作后再执行,例如我们打游戏,加载游戏,必须所有玩家都加载成功,才能进入游戏
2.如何工作
CountDownLatch是通过一个计数器来实现的,计数器的初始值为线程的数量,每当一个线程完成了自己的任务,计数器就会减1,当计数器值到达0时,它表示所有的线程已经完成任务,然后在闭锁上等待线程就可以恢复执行任务
3.API
CountDownLatch.countDown() //计数器减1
CountDownLatch.await();//等待所有线程执行完毕
三.CyclicBarrier
1.概念:
栅栏屏障，让一组线程到达一个屏障（也可以叫同步点）时被阻塞，直到最后一个线程
到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续运行。
CyclicBarrier默认的构造方法是CyclicBarrier（int parties），其参数表示屏障拦截的线
程数量，每个线程调用await方法告CyclicBarrier我已经到达了屏障，然后当前线程被阻塞。
2.API
cyclicBarrier.await()
CyclicBarrier必须等到所有初始化的线程都到达同步点,才能继续执行下一步,只要有一个没有到达,那么其他的线程就会一直等待
CyclicBarrier和CountDownLatch还有一个区别就是CyclicBarrier是可以重复使用的
网友评论