Java并发工具类CountDownLatch CyclicBarrier使用详解
CountDownLatch
CountDownLatch是一个同步辅助类，它允许一个或多个线程等待，直到其他线程完成一组操作。CountDownLatch有一个计数器，当计数器减为0时，等待的线程将被唤醒。计数器只能减少，不能增加。
示例：使用CountDownLatch等待所有线程完成任务
假设我们有一个任务需要三个子任务完成，我们可以使用CountDownLatch来等待所有子任务完成。
import java.util.concurrent.CountDownLatch;
public class CountDownLatchExample {
public static void main(String[] args) throws InterruptedException {
CountDownLatch latch = new CountDownLatch(3);
for (int i = 1; i <= 3; i++) {
final int taskNumber = i;
new Thread(() -> {
System.out.println("Task " + taskNumber + " started");
try {
Thread.sleep(1000 * taskNumber);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Task " + taskNumber + " completed");
latch.countDown();
}).start();
}
System.out.println("Waiting for all tasks to complete...");
latch.await();
System.out.println("All tasks completed");
}
}在这个示例中，我们创建了一个CountDownLatch并设置初始计数器为3。每个子任务完成后，调用latch.countDown()减少计数器。主线程调用latch.await()等待所有子任务完成。
CyclicBarrier
CyclicBarrier是一个同步辅助类，它允许一组线程相互等待，直到所有线程都准备好继续执行。当所有线程都到达屏障点时，屏障将打开。CyclicBarrier可以重复使用。
示例：使用CyclicBarrier同步多个线程
假设我们有三个线程需要在某个点同步，我们可以使用CyclicBarrier实现这个目的。
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierExample {
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(3, () -> System.out.println("All threads are ready to proceed"));
for (int i = 1; i <= 3; i++) {
final int taskNumber = i;
new Thread(() -> {
System.out.println("Task " + taskNumber + " is ready");
try {
barrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println("Task " + taskNumber + " is proceeding");
}).start();
}
}
}在这个示例中，我们创建了一个CyclicBarrier并设置参与者数量为3。每个线程在准备好继续执行之前调用barrier.await()。当所有线程都准备好时，屏障将打开，所有线程将继续执行。
Semaphore
Semaphore是一个计数信号量，它维护了一个许可集。线程可以请求许可，如果有可用的许可，线程将获得许可并继续执行。否则，线程将阻塞，直到有可用的许可。许可可以由任何线程释放。Semaphore可用于实现资源池、限制并发访问等。
示例：使用Semaphore限制并发访问
假设我们有一个只能同时处理三个请求的服务器，我们可以使用Semaphore来实现并发访问限制。
import java.util.concurrent.Semaphore;
public class SemaphoreExample {
public static void main(String[] args) {
Semaphore semaphore = new Semaphore(3);
for (int i = 1; i <= 10; i++) final int clientNumber = i;
new Thread(() -> {
try {
System.out.println("Client " + clientNumber + " is trying to connect");
semaphore.acquire();
System.out.println("Client " + clientNumber + " is connected");
Thread.sleep(2000);
System.out.println("Client " + clientNumber + " is disconnected");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
semaphore.release();
}
}).start();
}
}
}在这个示例中，我们创建了一个Semaphore并设置初始许可数量为3。每个客户端线程在连接服务器之前调用semaphore.acquire()请求许可。当许可可用时，线程将获得许可并继续执行。线程完成后，调用semaphore.release()释放许可。
Exchanger
Exchanger是一个同步辅助类，它允许两个线程在一个临界点交换数据。当两个线程都到达交换点时，它们将交换数据。Exchanger可以用于遗传算法、管道设计等。
示例：使用Exchanger交换数据
假设我们有两个线程，一个生成数据，另一个处理数据。我们可以使用Exchanger在这两个线程之间交换数据。
import java.util.concurrent.Exchanger;
public class ExchangerExample {
public static void main(String[] args) {
Exchanger<String> exchanger = new Exchanger<>();
new Thread(() -> {
try {
String data = "Data from producer";
System.out.println("Producer is sending: " + data);
String receivedData = exchanger.exchange(data);
System.out.println("Producer received: " + receivedData);
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
new Thread(() -> {
try {
String data = "Data from consumer";
System.out.println("Consumer is sending: " + data);
String receivedData = exchanger.exchange(data);
System.out.println("Consumer received: " + receivedData);
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
}
}在这个示例中，我们创建了一个Exchanger。生产者和消费者线程在交换数据前调用exchanger.exchange(data)。当两个线程都到达交换点时，它们将交换数据。
Phaser
Phaser是一个灵活的同步辅助类，它允许一组线程相互等待，直到所有线程都准备好继续执行。与CyclicBarrier类似，但Phaser更加灵活，可以动态调整参与者数量和支持多个阶段。
示例：使用Phaser同步多个线程
假设我们有三个线程需要在某个点同步，我们可以使用Phaser实现这个目的。
import java.util.concurrent.Phaser;
public class PhaserExample {
public static void main(String[] args) {
Phaser phaser = new Phaser(3);
for (int i = 1; i <= 3; i++) {
final int taskNumber = i;
new Thread(() -> {
System.out.println("Task " + taskNumber + " is ready");
phaser.arriveAndAwaitAdvance();
System.out.println("Task " + taskNumber + " is proceeding");
}).start();
}
}
}在这个示例中，我们创建了一个Phaser并设置参与者数量为3。每个线程在准备好继续执行之前调用phaser.arriveAndAwaitAdvance()。当所有线程都准备好时，屏障将打开，所有线程将继续执行。
这些并发工具类为Java多线程编程提供了强大的支持，帮助我们更轻松地实现各种同步和并发场景。希望这些示例能帮助你理解并掌握这些工具类的用法。
以上就是Java并发工具类CountDownLatch CyclicBarrier使用详解的详细内容，更多关于Java并发工具类的资料请关注脚本之家其它相关文章！
相关文章
这篇文章主要分享了JPA的几个小技巧，帮助大家更好的理解和学习使用Java，感兴趣的朋友可以了解下2021-03-03
在进行登录验证时，我们需要session或cookie会话进行验证，当我们脱离浏览器用app等向服务端发请求就没有session和cookie机制，这时我们就需要使用token令牌进行登录验证，本文就详细的介绍一下，感兴趣的可以了解一下2022-03-03
Spring MVC是一个广泛用于构建Java Web应用程序的框架,它提供了众多功能,包括双向数据绑定,在这篇文章中,我们将向Java新手介绍如何使用Spring MVC实现双向数据绑定,以及为什么这个特性如此重要,需要的朋友可以参考下2024-01-01
前端如何调用后端接口进行数据交互详解(axios和SpringBoot)
一般来讲前端不会给后端接口,而是后端给前端接口的情况比较普遍,下面这篇文章主要给大家介绍了关于前端如何调用后端接口进行数据交互的相关资料,文中通过实例代码介绍的非常详细,需要的朋友可以参考下2023-03-03
在SpringMVC 中，不管是编译异常还是运行时异常，都可以最终由 SpringMVC提供的异常处理器进行统一处理，这样就避免了随时随地捕获处理的繁琐性，这篇文章主要介绍了Spring MVC的三种异常处理方式 ,需要的朋友可以参考下2024-01-01
这篇文章主要介绍了如何优雅的实现将Collection转为Map,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2025-03-03
在使用javacv集成ffmpeg进行视频处理时,发现使用ffmpeg-6.0-1.5.9版本出现原生命令执行失败的问题,通过降级至ffmpeg-5.1.2-1.5.8版本,问题得到解决,此外,ffprobe可以用于获取视频属性,需确保视频片段属性一致性2024-11-11
这篇文章主要介绍了Java的二叉树排序以及遍历文件展示文本格式的文件树,是对二叉树结构学习的两个很好的实践,需要的朋友可以参考下2015-11-11
这篇文章主要为大家详细并深入的探讨Java多线程中的volatile变量，volatile用来确保将变量的更新操作通知到其他线程,保证了新值能立即同步到主内存,以及每次使用前立即从主内存刷新，感兴趣的小伙伴们可以参考一下2016-02-02
这篇文章主要介绍了详解Spring框架入门，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧,希望能给你带来帮助2021-07-07
最新评论