• java中的并发工具类


    前言

    在jdk的并发包中提供了几个非常有用的并发工具类。CountDownLatch,CyclicBarrier和Semaphore工具类提供了一种并发流程控制的手段,Exchanger工具类则提供了在线程间交换数据的一种手段。

    CountDownLatch

    CountDownLatch允许一个或多个线程等待其他线程完成操作。CountDownLatch构造函数接收一个int类型的参数做为计数器。当我们调用CountDownLatch的countDown方法时,N就会减1,CountDownLatch的await方法会阻塞当前线程,知道n变为零。但是如果有个别线程比较慢,我们又不想一直等下去,可以使用await(long time,TimeUnit unit),这个方法等待一定时间之后,就不会阻塞线程了。

    CyclicBarrier

    CyclicBarrier的字面意思就是可循环使用的屏障。它要做的事情是,让一组线程到达一个屏障时被阻塞,知道最后一个线程到达屏障后,屏障才会开门,所有被屏障拦截的线程才会继续进行。
    CyclicBarrier还提供一个更高级的构造函数CyclicBarrier(int parties,Runable barrier-Action),用于线程到达屏障时,优先执行barrierAction,方便处理复杂的业务场景.

    CountDownLatch 和 CyclicBarrier的区别

    看完上面的介绍,大家是不是觉得这两个框架是不是有点相似.其实两个框架确实是比较的相似,并且效果差不多,但是两个框架还是有不同的,不然就不会弄出两个框架来.
    CountDownLatch 的计数器只能使用一次,而CyclicBarrier的计数器可以使用reset()方法进行重置.

    Semaphore

    Semaphore是用来控制同时访问特定资源的线程数量的.也就是同一时间,只能有几个线程可以访问这个资源.Semaphore常常用于做流量控制,如数据库的连接等等.
    Semaphore其实在操作系统中也有,不知道java是不是借鉴的操作系统中的这个信号量.

    Exchager

    Exchager用于线程之间的数据交换.它提供一个同步点,在这个同步点,两个线程可以交换彼此的数据.这两个线程通过exchager方法交换数据,如果第一个线程先执行exchager方法,它会一直等待第二个线程也执行exchager方法,当两个线程都达到同步点的时候,这两个线程就可以交换数据,将各自线程生产出来的数据传递给对方.
    Exchager可以用于遗传算法,也可以用于校对工作.

    总结

    相比较与之前锁,volatile等单一的同步手段.并发工具类提供的同步手段更加丰富,希望大家遇到对应的业务场景的时候,可以使用起来.

  • 相关阅读:
    字符串的常用方法
    2022“杭电杯”中国大学生算法设计超级联赛(1)(6题newbie,后续会更新)
    Ngxin--源码分析 缓冲区链表
    vs vulkan 拓展层 和 验证层
    Lib文件和netlist的关系,DDC文件和netlist的区别
    Django-中间件(切面编程AOP)
    Ceres安装以及使用
    GUI程序设置
    系统编程之高效同步机制:条件变量
    unity 获取3D物体的方向数据
  • 原文地址:https://blog.csdn.net/qq_41820066/article/details/127970339