在程序执行期间，我会启动许多线程。线程的数量取决于用户定义的设置，但它们都会使用不同的变量执行相同的方法。
在某些情况下，需要在执行过程中进行清理，其中一部分是停止所有线程。但我不希望它们立即停止，而是设置一个变量供它们检查以终止它们。问题是，直到线程停止可能需要长达1/2秒的时间。但是，在清理可以继续之前，我需要确保所有线程都已停止。清理是由另一个线程执行的，因此从技术上讲，我需要此线程等待其他线程完成。
我想到了几种方法来实现这一点，但它们似乎都过于复杂。我希望有一种方法可以等待一组线程完成。是否存在类似的内容呢？
只需逐个连接它们：
for (Thread thread : threads) {
thread.join();
}
（您需要处理 InterruptedException，并且您可能希望在出现问题时提供超时，但这就是基本思路...）
thread.join();会让当前进程等待直到线程thread运行完毕，对吗？那么这里会发生什么情况呢，主进程将执行第二行并等待thread完成其工作，然后它将转到循环中的下一个thread，所以实际上主进程会等待第一个子线程正在运行，然后它将为下一个线程执行thread.join()，我理解对吗？ - Patriksthread完成（而不是启动）。期望的是，在我的回答代码执行之前，所有线程都已经在运行...它只是等待每个线程完成。 - Jon Skeetthread.join()，那么主线程将会被暂停，直到线程 thread 执行完成后主线程才会恢复。我理解得对吗？现在，假设有3个线程存储在变量 threads 中，那么 for 循环将会执行3次，第1次循环时，主线程将执行 .join() 方法，然后被系统暂停，当第一个线程执行完成后，主线程才能继续循环并处理下一个（第2个）线程元素。我理解的对吗？ - Patriks如果您使用的是Java 1.5或更高版本，则可以尝试使用CyclicBarrier。您可以将清理操作作为其构造函数参数传递，并在需要清理时在所有线程上调用barrier.await()。
你是否看过 java.util.concurrent 中的 Executor 类？ 你可以通过 ExecutorService 运行线程。 它会提供一个单一的对象，可用于取消线程或等待它们完成。
定义自己的实用方法（或方法）：
public static waitFor(Collection<? extends Thread) c) throws InterruptedException {
for(Thread t : c) t.join();
}
或者你可能有一个数组
public static waitFor(Thread[] ts) throws InterruptedException {
waitFor(Arrays.asList(ts));
}
或者您可以考虑使用 java.util.concurrent 库中的 CyclicBarrier 来实现多个线程之间的任意 汇合点。
JoinThreads join = new JoinThreads(threads);
for(int i = 0; i < threads.size(); i++) {
Thread justJoined = join.joinNextThread();
System.out.println("Done with a thread, just joined=" + justJoined);
}
并且源代码：
public static class JoinThreads {
java.util.concurrent.LinkedBlockingQueue<Thread> doneThreads =
new LinkedBlockingQueue<Thread>();
public JoinThreads(List<Thread> threads) {
for(Thread t : threads) {
final Thread joinThis = t;
new Thread(new Runnable() {
@Override
public void run() {
try {
joinThis.join();
doneThreads.add(joinThis);
}
catch (InterruptedException e) {
// "should" never get here, since we control this thread and don't call interrupt on it
}
}
}).start();
}
}
Thread joinNextThread() throws InterruptedException {
return doneThreads.take();
}
}