如何使用java的CountDownLatch线程计数器

一、CountDownLatch简介

CountDownLatch是java.util.concurrent包中的一个同步辅助类，它允许一个或多个线程一直等待，直到其他线程的操作执行完后再执行。它是一个典型的多线程计数器，可以指定一个数字，每调用一次countDown()方法，这个数字就减一，所有线程都可以通过await()方法阻塞自己，直到这个数字减为0，所有等待线程才会被唤醒。

二、使用步骤

1、创建CountDownLatch对象，指定计数器的初始值；

CountDownLatch latch = new CountDownLatch(10);

2、在需要等待的线程中调用await()方法，阻塞当前线程；

latch.await();

3、在其他线程中，调用countDown()方法，计数器值减一；

latch.countDown();

4、当计数器值减为0时，等待的线程会被唤醒继续执行。

三、示例代码

下面的示例代码演示了如何使用CountDownLatch，该示例有两个线程，一个线程负责等待，另一个线程负责计数，当计数器值减为0时，等待线程会被唤醒继续执行。

public class CountDownLatchTest {

public static void main(String[] args) {

CountDownLatch latch = new CountDownLatch(10);

Thread thread1 = new Thread(new CountDownLatchThread(latch));

Thread thread2 = new Thread(new CountDownLatchThread2(latch));

thread1.start();

thread2.start();

}

}

class CountDownLatchThread implements Runnable {

private CountDownLatch latch;

public CountDownLatchThread(CountDownLatch latch) {

this.latch = latch;

}

@Override

public void run() {

try {

System.out.println("线程" + Thread.currentThread().getName() + "正在执行");

Thread.sleep(3000);

System.out.println("线程" + Thread.currentThread().getName() + "执行完毕");

latch.countDown();

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}

class CountDownLatchThread2 implements Runnable {

private CountDownLatch latch;

public CountDownLatchThread2(CountDownLatch latch) {

this.latch = latch;

}

@Override

public void run() {

try {

latch.await();

System.out.println("线程" + Thread.currentThread().getName() + "继续执行");

} catch (InterruptedException e) {

e.printStackTrace();

}

}

}