JAVA中CountDownLatch怎么使用

45次阅读
没有评论

共计 1287 个字符,预计需要花费 4 分钟才能阅读完成。

在 Java 中,CountDownLatch 是一个同步辅助类,它可以让一个或多个线程等待其他线程完成操作后再继续执行。CountDownLatch 可以用于以下场景:

  1. 主线程等待多个子线程完成后再执行。
  2. 多个子线程等待主线程完成某个任务后再开始执行。

CountDownLatch 的使用步骤如下:

  1. 创建一个 CountDownLatch 对象,指定需要等待的线程数量。
  2. 在需要等待的线程中,调用 CountDownLatch 的 await() 方法,使线程进入等待状态,直到计数器减为 0。
  3. 在其他线程执行完需要等待的任务后,调用 CountDownLatch 的 countDown() 方法,将计数器减 1。
  4. 如果主线程需要等待其他线程完成后再执行,可以在主线程中调用 CountDownLatch 的 await() 方法,使主线程进入等待状态。
  5. 当计数器减到 0 时,所有等待的线程将被唤醒,继续执行。

下面是一个简单的示例代码:

import java.util.concurrent.CountDownLatch;
public class CountDownLatchExample {public static void main(String[] args) {
int threadCount = 5;
CountDownLatch latch = new CountDownLatch(threadCount);
for (int i = 0; i < threadCount; i++) {Thread thread = new Thread(new WorkerThread(latch));
thread.start();}
try {latch.await(); // 主线程等待所有子线程执行完毕
System.out.println("All threads have finished.");
} catch (InterruptedException e) {e.printStackTrace();
}
}
}
class WorkerThread implements Runnable {
private CountDownLatch latch;
public WorkerThread(CountDownLatch latch) {this.latch = latch;}
@Override
public void run() {
// 执行需要等待的任务
System.out.println("Thread " + Thread.currentThread().getName() + " is running.");
// 任务执行完毕后,调用 countDown() 方法将计数器减 1
latch.countDown();}
}

在上面的示例代码中,主线程创建了 5 个 WorkerThread 线程,并将 CountDownLatch 对象作为参数传递给它们。每个 WorkerThread 线程执行完任务后,调用 latch.countDown() 方法将计数器减 1。主线程调用 latch.await() 方法进入等待状态,直到计数器减为 0,所有子线程执行完成。最后,主线程输出 ”All threads have finished.”。

丸趣 TV 网 – 提供最优质的资源集合!

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-12-21发表,共计1287字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)