CyclicBarrier如何使用？

• CyclicBarrier 的中文意思是 "循環柵欄"，簡單理解就是一個可以循環利用的屏障。
• 用於讓多個線程阻塞在屏障處，當屏障達到放開的條件，所有被阻塞的線程會繼續執行，此時 CyclicBarrier 會自動重置。
• 阻塞線程在屏障處，調用 CyclicBarrier 對象的 await() 方法
• CyclicBarrier 內部主要通過了 ReentrantLock 和 Condition 實現
• CyclicBarrier 有兩個構造方法：

//parties 表示屏障攔截的線程數量
//barrierAction 表示最后一個達到的屏障的線程將執行 barrierAction
public CyclicBarrier(int parties)
public CyclicBarrier(int parties, Runnable barrierAction)

 

 

使用示例：

package constxiong.interview;

import java.util.concurrent.CyclicBarrier;

/**
 * 測試 CyclicBarrier 的使用
 * @author ConstXiong
 * @date 2019-12-25 19:22:50
 */
public class TestCyclicBarrier {

    public static void main(String[] args) {
        int parts = 10;
        final CyclicBarrier cb = new CyclicBarrier(parts, () -> {
            System.out.println(Thread.currentThread().getName() + ": I'am is last Thread");
        });
        
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + ": I'am come");
                try {
                    cb.await();
                } catch (Exception e) {
                    e.printStackTrace();
                }
                System.out.println(Thread.currentThread().getName() + ": go together");
            }).start();
        }
        
    }
    
}

 

 

打印結果：

Thread-2: I'am come
Thread-0: I'am come
Thread-1: I'am come
Thread-4: I'am come
Thread-3: I'am come
Thread-6: I'am come
Thread-9: I'am come
Thread-5: I'am come
Thread-7: I'am come
Thread-8: I'am come
Thread-8: I'am is last Thread
Thread-8: go together
Thread-2: go together
Thread-0: go together
Thread-1: go together
Thread-4: go together
Thread-3: go together
Thread-6: go together
Thread-5: go together
Thread-9: go together
Thread-7: go together

 

 

CountDownLatch 和 CyclicBarrier 簡單比較

• CountDownLatch 是一個(或多個)線程等待 N 個線程完成某件事情之后再執行；CyclicBarrier 是每個線程相互等待，即 N 個線程都被攔截之后，然后一起放開執行
• CountDownLatch 無法重置，不可復用；CyclicBarrier 計數到 parts 值時會自動重置，可復用

原文鏈接
 

---

• Java 自學經歷
• Java 面試題 H5
• Java 面試題小程序