zoukankan      html  css  js  c++  java
  • CyclicBarrier、CountDownLatch与Semaphore的小记

    CyclicBarrier:

    适合的业务场景,比如

    1)、,现有一大任务,需要得到全年的统计数据的,这个工作量是巨大的,那么可以将其分割为12个月的子任务,各个子任务相互独立,当所有子任务完成了,则就可以进行全年统计了,这样大大提升了统计效率。

    2)、大家一起去郊游,由于大家住的地方比较分散,故需要一个集合点之后一起出发,这样大家才能玩得开心嘛。

    。。。。等等

    就是当有一个大任务时,需要分配多个子任务去执行,只有当所有的子任务都执行完成后,才能执行主任务。

    //阻塞等待
    public int await()

    CountDownLatch:

    适合的业务场景,比如

    1)、运动会中赛跑项目,之后所有的赛跑运动员准备好了,此时裁判才能宣布该赛跑项目正式开始,裁判才能打出发信枪;当参与此次赛跑项目的所有的运动员都跑完了,此次赛跑项目才能算结束,才能统计出比赛名次。

    。。。。等等

    就是所有的准备好了,才能开始;或者是所有的都结束了,才能算结束。

    //阻塞等待,直到计数器清零
    public void await()
    
    //阻塞等待,直到等待到最长时间,当等待时间超过设置时间时,计数器还没有清零,则返回false,否则返回true
    public boolean await(long timeout, TimeUnit unit)
    
    //计数器减一,当计数器清零时,await的线程会被唤醒,线程继续执行
    public void countDown()
    
    //获取当前计数器的大小
    public long getCount()

    Semaphore:

    适合的业务场景,比如

    1)、当有10个人去上茅厕,但是只有5个坑,即只能同时5个人使用,只有当一个人不使用坑了,另一个人才能使用该空闲的坑,一直维持着只能同时5个人使用。

    2)、当停车场来了100辆车时,但是只有30个停车位,即只能同时提供30个车辆停放,只有当一辆车开走了,另一辆车才能进入该空闲的停车位,一直维持着只能同时提供30个停车位。

    。。。。等等

    就是同时只能提供有限的,走一个才能进一个。

    //申请获取许可,当没有剩余的许可时,则被阻塞
    public void acquire()
    
    //释放一个许可
    public void release()

    总结:

    CountDownLatch是等待一组线程执行完毕后才能继续执行
    
     CyclicBarrier是能让一组线程达到一个同步点时被阻塞,直到最后一个线程达到,阻塞才会消失,其是可以循环使用的
    
     Semaphore是只允许一定数量的线程同时执行
  • 相关阅读:
    RQNOJ 342 最不听话的机器人:网格dp
    RQNOJ 329 刘翔!加油!:01背包
    RQNOJ 57 找啊找啊找GF:01背包
    RQNOJ 202 奥运火炬登珠峰:01背包
    RQNOJ 201 奥运大包围:LIS + 拼链成环
    2017SN多校D1T2 note:dp
    2017SN多校D1T1 loveletter:模拟
    HDU 2157 How many ways??:矩阵快速幂【i到j共经过k个节点的方法数】
    poj 3764 The xor-longest Path
    bzoj 1192 鬼谷子的钱袋
  • 原文地址:https://www.cnblogs.com/zhaoyan001/p/10775665.html
Copyright © 2011-2022 走看看