在并发编程中,CyclicBarrier和CountDownLatch是两个常用的同步工具类。它们都可以用于线程之间的等待和协调,但在使用方式和功能上有一些区别。本文将深入探讨CyclicBarrier和CountDownLatch的区别,并给出相应的代码示例。
CyclicBarrier是Java提供的一种同步辅助类,它可以让一组线程互相等待,直到到达某个公共屏障点。当所有线程都到达屏障点后,这些线程才能继续执行后续的操作。
CountDownLatch也是Java提供的一种同步辅助类,它可以让一个或多个线程等待,直到其他线程执行完一组操作后再继续执行。
下面是CyclicBarrier和CountDownLatch的区别对比:
CyclicBarrier的使用方式相对复杂一些,需要明确指定线程的数量,并在每个线程到达屏障点后执行特定的操作。
CountDownLatch的使用方式相对简单,只需要调用await()
方法等待其他线程执行完一组操作即可。
CyclicBarrier可以重用,即在所有线程到达屏障点后,屏障会自动重置,线程可以继续使用。
CountDownLatch不能重用,一旦计数器减到0,就无法再次使用。
CyclicBarrier等待线程的方式是通过await()
方法进行等待,可以选择等待一定的时间或者等待其他线程到达。
CountDownLatch等待线程的方式是通过await()
方法进行等待,直到计数器减到0。
CyclicBarrier主要用于线程之间的等待和协调,在所有线程到达屏障点后可以执行特定的操作。
CountDownLatch主要用于等待其他线程执行完一组操作后再继续执行。
下面给出一个简单的CyclicBarrier和CountDownLatch的代码示例:
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.CountDownLatch;
public class CyclicBarrierDemo {
public static void main(String[] args) throws InterruptedException {
final int threadCount = 5;
final CyclicBarrier cyclicBarrier = new CyclicBarrier(threadCount, () -> {
System.out.println("所有线程已到达屏障点");
});
for (int i = 0; i < threadCount; i++) {
final int threadNum = i;
new Thread(() -> {
try {
System.out.println("线程" + threadNum + "已到达屏障点");
cyclicBarrier.await();
System.out.println("线程" + threadNum + "继续执行");
} catch (InterruptedException | BrokenBarrierException e) {
e.printStackTrace();
}
}).start();
}
}
}
public class CountDownLatchDemo {
public static void main(String[] args) throws InterruptedException {
final int threadCount = 5;
final CountDownLatch countDownLatch = new CountDownLatch(threadCount);
for (int i = 0; i < threadCount; i++) {
final int threadNum = i;
new Thread(() -> {
try {
System.out.println("线程" + threadNum + "开始执行");
Thread.sleep(1000);
System.out.println("线程" + threadNum + "执行完毕");
countDownLatch.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
}
}).start();
}
countDownLatch.await();
System.out.println("所有线程执行完毕");
}
}
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。
原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。
如有侵权,请联系 cloudcommunity@tencent.com 删除。