共计 1098 个字符,预计需要花费 3 分钟才能阅读完成。
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"。
丸趣 TV 网 – 提供最优质的资源集合!
正文完