闭锁是一种同步工具类,可以延迟线程的进度直到其达到终止状态。形象一点就是,闭锁就是一扇关闭的大门,在闭锁达到结束条件之前,这扇门是关闭的,没有任何线程可以通过。而一旦条件达到,就像开闸泄洪一样,万马奔腾,瞬间达到高并发。在此我希望模拟高并发的瞬间,而不是依次的启动线程,让其相对依次的不可控执行。当然,这只是一种使用的方法,更多的使用闭锁可以确保某些活动直到其他活动都完成后才继续执行。
CountDownLatch是一种灵活的闭所实现。闭锁状态包括一个计数器,可以初始化为一个正数,表示需要等待的时间数量,countdown方法递减计数器,表示一个事件已经发生。await方法等待计数器为零,表示所有时间已经发生。如果计数器非零,则await会一直阻塞,知道计数器为零,或者线程中断,等待超时。
public class CountDownLatchDemo extends Thread {
public static CountDownLatch startGate = new CountDownLatch(1);
public static CountDownLatch endGate = new CountDownLatch(2000);
private String name;
public CountDownLatchDemo(String name) {
this.name = name;
}
public void run() {
try {
startGate.await();
// do what you want
System.out.println(Thread.currentThread().getName() + "=" + name);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
endGate.countDown();
}
}
public static void main(String[] args) throws InterruptedException {
for (int i = 0; i < 2000; i++) {
CountDownLatchDemotd = new CountDownLatchDemo(String.valueOf(i));
td.start();
}
long start = System.nanoTime();
CountDownLatchDemo.startGate.countDown();
CountDownLatchDemo.endGate.await();
long end = System.nanoTime();
System.out.println("time is " + String.valueOf(end - start));
}
}