阅读量:0
Java中可以使用CountDownLatch类来等待多个线程结束。
CountDownLatch类是Java提供的一个同步辅助类,它可以使一个或多个线程等待其他线程完成操作后再继续执行。
具体步骤如下:
- 创建一个CountDownLatch对象,并将计数器初始化为线程数。
- 在每个线程的操作完成后,调用CountDownLatch对象的countDown()方法,将计数器减1。
- 在主线程中,调用CountDownLatch对象的await()方法,等待所有线程完成操作,当计数器为0时,主线程恢复执行。
示例代码如下:
import java.util.concurrent.CountDownLatch; public class WaitMultipleThreads { 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 MyRunnable(latch)); thread.start(); } try { latch.await(); // 等待所有线程执行完成 System.out.println("All threads have finished."); } catch (InterruptedException e) { e.printStackTrace(); } } static class MyRunnable implements Runnable { private final CountDownLatch latch; public MyRunnable(CountDownLatch latch) { this.latch = latch; } @Override public void run() { // 线程操作逻辑 // ... latch.countDown(); // 线程执行完毕,计数器减1 } } }
在这个示例中,首先创建了一个CountDownLatch对象,并将计数器初始化为5。然后通过一个循环创建了5个线程,并将CountDownLatch对象作为参数传递给每个线程的构造函数。
在每个线程的run()方法中,执行线程操作的逻辑,并在最后调用latch.countDown()方法将计数器减1。
最后,在主线程中调用latch.await()方法,等待所有线程执行完成。当计数器为0时,主线程恢复执行,输出"All threads have finished"。