同步工具类可以是任何一个对象,只要它根据其自身的状态来协调线程的控制流。阻塞队列可以作为同步工具类,其他类型的同步工具类还包括 信号量(Semaphore)、栅栏(CyclicBarrier)以及闭锁(Latch)。
本文重点介绍 CountDownLatch的用法与应用场景。
CountDownLatch
CountDownLatch 是一种灵活的闭锁实现,它可以使一个或多个线程等待一组事件发生。CountDownLatch包括一个计数器,该计数器被初始化为一个正整数,表示需要等待的事件数量。countDown方法递减计数器,表示有一个事件已经发生了,而await方法等待计数器达到零,这表示所有需要等待的事件都已经发生。
package com.bytebeats.concurrent.api;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
/**
* 任务计时
*
* @author Ricky Fung
* @create 2017-04-24 23:01
*/
public class CountDownLatchDemo {
public static void main(String[] args) throws InterruptedException {
CountDownLatchDemo demo = new CountDownLatchDemo();
long time = demo.timeTasks(5, new Runnable() {
@Override
public void run() {
Random random = new Random();
int time = random.nextInt(1000);
try {
System.out.println("thread "+Thread.currentThread().getName()+ " sleep "+time);
TimeUnit.MILLISECONDS.sleep(time);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
System.out.println("耗时:"+time);
}
public long timeTasks(int threadNum, final Runnable task) throws InterruptedException {
final CountDownLatch startGate = new CountDownLatch(1); //开始
final CountDownLatch endGate = new CountDownLatch(threadNum); //结束
for(int i=0; i<threadNum; i++){
Thread thread = new Thread(){
@Override
public void run() {
try {
startGate.await();
System.out.println("thread "+Thread.currentThread().getName()+ " start");
try {
task.run();
System.out.println("thread "+Thread.currentThread().getName()+ " end");
} finally {
endGate.countDown();
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
thread.start();
}
long start = System.nanoTime();
startGate.countDown();
endGate.await();
long end = System.nanoTime();
return end - start;
}
}
CountDownLatch与CyclicBarrier的区别
CountDownLatch 可以使一个线程或者一组线程等待一组事件的发生,调用await和countDown方法。
CyclicBarrier能阻塞一组线程直到某个时间发生。它与CountDownLatch的区别在于:CountDownLatch用于等待事件,而CyclicBarrier用于等待其他线程。
另外,CyclicBarrier可以被重置,而CountDownLatch不可以。