天天看點

并發:CyclicBarrier和CountDownLatch的差別。

CountDownLatch的計數器隻能使用一次,而CyclicBarrier的計數器可以使用reset()方法重置。是以CyclicBarrier能處理更為複雜的業務場景。例如,如果計算發生錯誤,可以重置計數器,并讓線程重新執行一次。

CyclicBarrier還提供其他有用的方法,比如getNumberWaiting方法可以擷取CyclicBarrier阻塞的線程數量。isBroken()方法用來了解阻塞的線程是否被中斷。下面代碼執行完之後會傳回true,其中isBroken的使用代碼如下所示。

public class Test {
	static CyclicBarrier c = new CyclicBarrier(2);
	public static void main(String[] args) {
		Thread thread = new Thread(new Runnable() {
			@Override
			public void run() {
				try {
					c.await();
				} catch (InterruptedException | BrokenBarrierException e) {
				}
			}
		});
		thread.start();
		thread.interrupt();
		try {
			c.await();
		} catch (InterruptedException | BrokenBarrierException e) {
			System.out.println(c.isBroken());
		}
	}
}