一文掌握Java中的CyclicBarrier、CountDownLatch和Semaphore

2024-05-28 08:04

本文主要是介绍一文掌握Java中的CyclicBarrier、CountDownLatch和Semaphore,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1.CountDownLatch

1.1 介绍和用途

CountDownLatch 是一个同步助手类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。

1.2 工作原理

它通过一个计数器来实现,我们初始化 CountDownLatch 对象时指定计数器的值,每当一个指定的操作执行完成后,计数值就减一。当计数值达到零时,它表示所有需要等待的操作都完成了,此时阻塞在 CountDownLatch 上的线程就可以恢复执行任务。

1.3 使用场景和示例代码

CountDownLatch 经常用于确保某些操作在继续执行应用程序剩余部分之前完成,例如,服务器的服务依赖在接受请求前必须初始化完成。

import java.util.concurrent.CountDownLatch;
public class ServiceLoader {// 初始计数器为3,表示需要等待3个服务加载private static final CountDownLatch latch = new CountDownLatch(3);public static void main(String[] args) throws InterruptedException {// 启动服务加载线程new Thread(new Service("Service 1", latch)).start();new Thread(new Service("Service 2", latch)).start();new Thread(new Service("Service 3", latch)).start();// 主线程等待服务加载完成latch.await();System.out.println("所有服务已加载完成,服务可以开始接收请求...");}static class Service implements Runnable {private final String name;private final CountDownLatch latch;public Service(String name, CountDownLatch latch) {this.name = name;this.latch = latch;}@Overridepublic void run() {try {// 模拟服务加载耗时操作Thread.sleep((long) (Math.random() * 1000));System.out.println(name + " 服务加载完成.");// 服务加载完成后,计数器减一latch.countDown();} catch (InterruptedException e) {Thread.currentThread().interrupt();}}}
}

1.4 注意事项和最佳实践

CountDownLatch 的计数器无法被重置,如果需要一个能够重置计数的版本,可以考虑使用 CyclicBarrier。在使用时还需注意异常处理,避免由于异常造成的线程永远等待的情况。

2.CyclicBarrier

2.1 介绍和用途

CyclicBarrier 是一个同步助手类,它允许一组线程互相等待,直到所有线程都到达一个公共的屏障点(Barrier Point)后才继续执行。

2.2 工作原理

CyclicBarrier 通过内部计数器来跟踪到达屏障点的线程数。当线程到达屏障点时,它调用 await() 方法,并阻塞直到指定数量的线程都到达了屏障点。此时,屏障打开,所有阻塞的线程将继续执行。不同于 CountDownLatchCyclicBarrier 是可重用的。

2.3 使用场景和示例代码

CyclicBarrier 常用于多线程计算数据的场景,需要等到全部线程完成计算,才能进行下一步的处理。

import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.BrokenBarrierException;
public class DataProcessor {private static final int NUMBER_OF_THREADS = 3;private static CyclicBarrier barrier = new CyclicBarrier(NUMBER_OF_THREADS, new Runnable() {@Overridepublic void run() {// 当所有线程到达屏障点时执行System.out.println("所有计算完成,进行数据合并...");}});public static void main(String[] args) {for(int i = 0; i < NUMBER_OF_THREADS; i++) {new Thread(new Worker(i)).start();}}static class Worker implements Runnable {private int id;public Worker(int id) {this.id = id;}@Overridepublic void run() {try {// 模拟数据处理System.out.println("线程 #" + id + " 正在处理数据...");Thread.sleep((long) (Math.random() * 1000));System.out.println("线程 #" + id + " 数据处理完成,等待其他线程...");// 等待其他线程都执行到这个点barrier.await();System.out.println("线程 #" + id + " 继续后续操作...");} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}}}
}

2.4 与CountDownLatch的比较

与 CountDownLatch 相比,CyclicBarrier 可以在所有等待线程都被释放后重置计数器,而 CountDownLatch 不能重置。

2.5 注意事项和最佳实践

使用 CyclicBarrier 时需要注意,如果任何线程在等待过程中因为中断或者超时而提前离开屏障点, 或者等待线程的数目永远不足以达到屏障点,这将导致所有在屏障点等待的线程抛出 BrokenBarrierException。因此,在使用时需要妥善处理这些可能的异常场景。
为了避免这种情形,可以在 await 方法中设置一个超时时间,并适当处理 TimeoutException。同时,可以通过 isBroken 方法检查屏障点的状态,以便在必要时对线程进行重新安排或者重置屏障点。
除此之外,设计上建议只在所有参与线程要完成的任务确实需要互相等待时才使用 CyclicBarrier,在任务独立的情况下使用 CountDownLatch 会更为合适。

3.Semaphore

3.1 介绍和用途

Semaphore(信号量)是一种基于计数的同步机制,它可以用来控制同时访问特定资源的线程数量,是实现资源池或者限制容量的一个有力工具。

3.2 工作原理

Semaphore 管理一组许可证(permits),线程可以通过 acquire() 方法获取许可证,如果 Semaphore 内部计数为零,表示没有许可证可用,线程将会阻塞直到有许可证被释放。相反,线程完成任务后,可以通过 release() 方法释放许可证,并将其返回给信号量。

3.3 使用场景和示例代码

Semaphore 通常用于对资源池进行控制,比如数据库连接池,限制同时访问的连接数,或者在限流控制中限制同时执行的线程数量。

import java.util.concurrent.Semaphore;
public class ResourcePool {private static final int MAX_AVAILABLE = 5;private final Semaphore available = new Semaphore(MAX_AVAILABLE, true);public Object getItem() throws InterruptedException {available.acquire();try {// 模拟获取资源的操作return getNextAvailableItem();} finally {// 保证在资源使用后一定会释放许可证available.release();}}// 此处省略了资源管理的其他逻辑...public static void main(String[] args) {final ResourcePool pool = new ResourcePool();for (int i = 0; i < 10; i++) {new Thread(() -> {try {Object item = pool.getItem();// 模拟使用资源System.out.println(Thread.currentThread().getName() + " 获取了资源");Thread.sleep((long) (Math.random() * 1000));// 假设这里是使用资源完成后的操作} catch (InterruptedException e) {Thread.currentThread().interrupt();}}).start();}}// 此处省略了getNextAvailableItem方法的实现,它应该负责分配资源
}

在以上代码示例中,我们设置了最大并发数,并通过 Semaphore 来限制访问资源的线程数。当所有许可证都被占用时,后来的线程将会等待直到有线程释放许可证。

3.4 和其他同步工具的比较

相比其他同步工具,Semaphore 提供了对资源的并发访问控制,而 CountDownLatch 和 CyclicBarrier 更侧重于线程的协调和等待。

3.5 注意事项和最佳实践

使用 Semaphore 时,要确保在资源使用后,准确无误地释放许可证,否则可能会导致其他线程永久等待。在实际应用中,尤其在复杂的业务逻辑里,通常建议使用 try-finally` 语句确保许可证的正确释放。
同时,合理配置许可证的数量对于系统的稳定性和性能至关重要。对于资源竞争激烈的场景,设置过少的许可证可能会导致系统响应时间增长;反之,设置过多的许可证则可能会超出系统资源的实际承载能力,造成资源的浪费或系统崩溃。

这篇关于一文掌握Java中的CyclicBarrier、CountDownLatch和Semaphore的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1009989

相关文章

Java的栈与队列实现代码解析

《Java的栈与队列实现代码解析》栈是常见的线性数据结构,栈的特点是以先进后出的形式,后进先出,先进后出,分为栈底和栈顶,栈应用于内存的分配,表达式求值,存储临时的数据和方法的调用等,本文给大家介绍J... 目录栈的概念(Stack)栈的实现代码队列(Queue)模拟实现队列(双链表实现)循环队列(循环数组

Java中Switch Case多个条件处理方法举例

《Java中SwitchCase多个条件处理方法举例》Java中switch语句用于根据变量值执行不同代码块,适用于多个条件的处理,:本文主要介绍Java中SwitchCase多个条件处理的相... 目录前言基本语法处理多个条件示例1:合并相同代码的多个case示例2:通过字符串合并多个case进阶用法使用

Java中的Lambda表达式及其应用小结

《Java中的Lambda表达式及其应用小结》Java中的Lambda表达式是一项极具创新性的特性,它使得Java代码更加简洁和高效,尤其是在集合操作和并行处理方面,:本文主要介绍Java中的La... 目录前言1. 什么是Lambda表达式?2. Lambda表达式的基本语法例子1:最简单的Lambda表

Java中Scanner的用法示例小结

《Java中Scanner的用法示例小结》有时候我们在编写代码的时候可能会使用输入和输出,那Java也有自己的输入和输出,今天我们来探究一下,对JavaScanner用法相关知识感兴趣的朋友一起看看吧... 目录前言一 输出二 输入Scanner的使用多组输入三 综合练习:猜数字游戏猜数字前言有时候我们在

Spring Security+JWT如何实现前后端分离权限控制

《SpringSecurity+JWT如何实现前后端分离权限控制》本篇将手把手教你用SpringSecurity+JWT搭建一套完整的登录认证与权限控制体系,具有很好的参考价值,希望对大家... 目录Spring Security+JWT实现前后端分离权限控制实战一、为什么要用 JWT?二、JWT 基本结构

java解析jwt中的payload的用法

《java解析jwt中的payload的用法》:本文主要介绍java解析jwt中的payload的用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录Java解析jwt中的payload1. 使用 jjwt 库步骤 1:添加依赖步骤 2:解析 JWT2. 使用 N

一文带你搞懂Python中__init__.py到底是什么

《一文带你搞懂Python中__init__.py到底是什么》朋友们,今天我们来聊聊Python里一个低调却至关重要的文件——__init__.py,有些人可能听说过它是“包的标志”,也有人觉得它“没... 目录先搞懂 python 模块(module)Python 包(package)是啥?那么 __in

springboot项目如何开启https服务

《springboot项目如何开启https服务》:本文主要介绍springboot项目如何开启https服务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录springboot项目开启https服务1. 生成SSL证书密钥库使用keytool生成自签名证书将

Java实现优雅日期处理的方案详解

《Java实现优雅日期处理的方案详解》在我们的日常工作中,需要经常处理各种格式,各种类似的的日期或者时间,下面我们就来看看如何使用java处理这样的日期问题吧,感兴趣的小伙伴可以跟随小编一起学习一下... 目录前言一、日期的坑1.1 日期格式化陷阱1.2 时区转换二、优雅方案的进阶之路2.1 线程安全重构2

Java中的JSONObject详解

《Java中的JSONObject详解》:本文主要介绍Java中的JSONObject详解,需要的朋友可以参考下... Java中的jsONObject详解一、引言在Java开发中,处理JSON数据是一种常见的需求。JSONObject是处理JSON对象的一个非常有用的类,它提供了一系列的API来操作J