CountDownLatch和CyclicBarrier都是Java并发库中的同步辅助工具,它们都可以用来控制多个线程之间的执行顺序,但它们之间存在一些关键区别:
- CountDownLatch:
- CountDownLatch是一个同步辅助类,它允许一个或多个线程等待直到一组操作完成。
- 它的工作原理是:一个计数器,初始值为非零。每当一个操作完成时,计数器减1。当计数器减至0时,所有等待的线程被释放。
- CountDownLatch是不可重用的,一旦计数器减至0,它就不能再次使用。
- CountDownLatch适用于确保某些线程在其他线程完成特定任务之前不会继续执行的场景。
示例代码:
CountDownLatch latch = new CountDownLatch(3); new Thread(() -> { // 执行任务 latch.countDown(); }).start(); new Thread(() -> { // 执行任务 latch.countDown(); }).start(); new Thread(() -> { // 执行任务 latch.countDown(); }).start(); latch.await(); // 等待所有线程完成任务
- CyclicBarrier:
- CyclicBarrier是一个同步辅助类,它允许一组线程相互等待,直到所有线程都准备好继续执行。
- 它的工作原理是:一个计数器,初始值为非零。每当一个线程到达屏障点时,计数器减1。当计数器减至0时,所有等待的线程被释放,并且计数器重置为初始值。
- CyclicBarrier是可重用的,因为它会在计数器重置后再次投入使用。
- CyclicBarrier适用于多个线程需要相互等待,直到所有线程都准备好继续执行的场景。
示例代码:
CyclicBarrier barrier = new CyclicBarrier(3); new Thread(() -> { // 执行任务 try { barrier.await(); // 等待其他线程 } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }).start(); new Thread(() -> { // 执行任务 try { barrier.await(); // 等待其他线程 } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }).start(); new Thread(() -> { // 执行任务 try { barrier.await(); // 等待其他线程 } catch (InterruptedException | BrokenBarrierException e) { e.printStackTrace(); } }).start();
总结:
- CountDownLatch用于确保某些线程在其他线程完成特定任务之前不会继续执行,不可重用。
- CyclicBarrier用于多个线程需要相互等待,直到所有线程都准备好继续执行,可重用。