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());
}
}
}