JUC- 常用辅助类

6.1 CountDownLatch

6.1.1 基本概念

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-Qp6uFu8K-1614138326808)(https://guardwhy.oss-cn-beijing.aliyuncs.com/img/javaSE/se2/33-javase.png)]

6.1.2 底层源码

6.1.3 代码示例

package cn.guardwhy.juc01;import java.util.concurrent.CountDownLatch;public class CountDownLatchDemo01 {public static void main(String[] args) throws InterruptedException {// 1.创建countDownLatch对象CountDownLatch countDownLatch = new CountDownLatch(6);for (int i = 0; i <=6 ; i++) {new Thread(()->{System.out.println(Thread.currentThread().getName() + " Start");// 数量-1countDownLatch.countDown();}, String.valueOf(i)).start();}// 等待计数器归零，然后再往下执行。countDownLatch.await();System.out.println("End..");}
}

原理分析

CountDownLatch 主要有两个方法，当一个或多个线程调用 await 方法时，这些线程会阻塞其他线程调用CountDown方法会将计数器减1(调用CountDown方法的线程不会阻塞）当计数器变为0时，await 方法阻塞的线程会被唤醒，继续执行。

6.2 CyclicBarrier

6.2.1 基本概念

加法计数器

6.2.2 代码示例

package cn.guardwhy.juc01;import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;public class CyclicBarrierDemo01 {public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{System.out.println("NBA王朝成立");});for (int i = 0; i <=7 ; i++) {int temp = i;new Thread(()->{System.out.println(Thread.currentThread().getName() + "拿到" + temp + "个总冠军");try {// 等待操作cyclicBarrier.await();} catch (InterruptedException e) {e.printStackTrace();} catch (BrokenBarrierException e) {e.printStackTrace();}}).start();}}
}

6.3 Semaphore

6.3.1 基本概念

信号量;信号灯;信号

6.3.2 代码示例

package cn.guardwhy.juc01;import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;public class SemaphoreDemo01 {public static void main(String[] args) {// 线程数量Semaphore semaphore = new Semaphore(3);// 多线程for (int i = 0; i <=5 ; i++) {new Thread(()->{try {// acquire() 得到semaphore.acquire();System.out.println(Thread.currentThread().getName() + "抢到车位");TimeUnit.SECONDS.sleep(2);System.out.println(Thread.currentThread().getName() + "离开车位");} catch (InterruptedException e) {e.printStackTrace();} finally {// 释放资源semaphore.release();}}).start();}}
}

6.3.3 原理分析

CyclicBarrier：指定个数线程执行完毕再执行操作。

semaphore：同一时间只能有指定数量个得到线程。

在信号量上两种操作

acquire（获取）

当一个线程调用 acquire 操作时，他要么通过成功获取信号量（信号量-1）
要么一直等下去，直到有线程释放信号量，或超时。

release （释放）

实际上会将信号量的值 + 1，然后唤醒等待的线程。
信号量主要用于两个目的：一个是用于多个共享资源的互斥使用，另一个用于并发线程数的控制。

作用: 多个共享资源互斥的使用，并发限流，控制最大的线程数！！！

JUC- 常用辅助类相关推荐

JUC常用辅助类CountDownLatch、CyclicBarrier、Semaphore
一.CountDownLatch 简介:CountDownLatch倒计时计数锁,其主要有俩个方法,当一个或多个线程调用await()方法时,这些线程会阻塞. 其他线程调用countDown()方法会 ...
浅谈Java锁,与JUC的常用类,集合安全类,常用辅助类,读写锁,阻塞队列,线程池,ForkJoin,volatile,单例模式不安全,CAS,各种锁
浅谈JUC的常用类 JUC就是java.util.concurrent-包下的类回顾多线程 Java默认有几个线程? 2 个 mian.GC Java 真的可以开启线程吗? 开不了,点击源码得知:本 ...
JUC并发编程之Callable接口、JUC三大辅助类
目录 8. Callable接口 8.1 创建线程的多种方式 8.2 概述 8.3 用Callable接口创建Thred线程 8.4 小结(重点) 9. JUC 三大辅助类 9.1 概述 9.2 减少 ...
JUC 高并发编程之JUC三大辅助类
JUC 高并发编程之JUC三大辅助类 JUC 中提供了三种常用的辅助类,通过这些辅助类可以很好的解决线程数量过多时 Lock 锁的频繁操作.这三种辅助类为: CountDownLatch: 减少计数 ...
JUC介绍--常用辅助类(CountDownLatch CyclicBarrier Semaphore)
CountDownLatch减法计数器每次有线程调用countDownLatch.countDown()数量就-1 数量减到0时,countDownLatch.await()会被唤醒,继续向下执行 ...
JUC 常用 4 大并发工具类
欢迎关注方志朋的博客,回复"666"获面试宝典什么是JUC? JUC就是java.util.concurrent包,这个包俗称JUC,里面都是解决并发问题的一些东西该包的位置位 ...
JUC——JUC强大辅助类讲解
文章目录 1:JUC是什么 2:倒计数器--CountDownLatchDemo 3:循环栅栏--CyclicBarrier 4:允许多个线程同时访问--Semaphore(信号量) 1:JUC是什么 ...
JUC 三大辅助类解读
目录减少计数 CountDownLatch 构造办法代码实战循环栅栏 CyclicBarrier 构造器代码实战信号灯 Semaphore 构造办法代码实战 JUC 中提供了三种常用的辅助 ...
Day127.JUC：线程间通信(Conditon)、并发容器类(CopyOnWrite)、JUC强大辅助类、Callable
. 目录一.线程间通信线程间通信改造成Lock版 Condition 定制化调用通信 Condition 二.并发容器类 (解决集合安全问题) CopyOnWrite 写时拷贝技术三.JUC ...
JUC: 同步辅助类
java.util.concurrent包下,有一些关于同步的辅助工具类,比如CountDownLatch.CyclicBarrier等. CountDownLatch 允许一个或多个线程等待直到在其 ...