java.util.concurrent.CountDownLatch
java.util.concurrent.CountDownLatch 是一个闭锁实现，它允许一个或多个线程等待一系列指定操作的完成。
CountDownLatch 以一个给定的数量初始化。countDown() 每被调用一次，这一数量就减一。通过调用 await()方法之一，线程可以阻塞等待这一数量到达零。
以下是一个简单示例。Decrementer 三次调用 countDown() 之后，等待中的 Waiter 才会从 await() 调用中释放出来 :
CountDownLatch 以一个给定的数量初始化。countDown() 每被调用一次，这一数量就减一。通过调用 await()方法之一，线程可以阻塞等待这一数量到达零。
以下是一个简单示例。Decrementer 三次调用 countDown() 之后，等待中的 Waiter 才会从 await() 调用中释放出来 :
public class CountDownLatchTest {
public static void main(String[] args) throws InterruptedException {
CountDownLatchTest lt = new CountDownLatchTest();
CountDownLatch latch = new CountDownLatch(3);
Waiter waiter = lt.new Waiter(latch);
Decrementer decrementer = lt.new Decrementer(latch);
new Thread(waiter).start();
new Thread(decrementer).start();
}
public class Waiter implements Runnable {
CountDownLatch latch = null;
public Waiter(CountDownLatch latch) {
this.latch = latch;
}
public void run() {
try {
System.out.println("wait for latch count down");
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Waiter Released");
}
}
public class Decrementer implements Runnable {
CountDownLatch latch = null;
public Decrementer(CountDownLatch latch) {
this.latch = latch;
}
public void run() {
for (int i = 0; i < 3; i++) {
try {
Thread.sleep(1000);
System.out.println("latch count down");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
this.latch.countDown();//建议将此方法放在finally中执行
}
}
}
}
}
0
赞
- 所属分类： 后端技术
- 本文标签：
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
6、 golang
-
7、 openharmony