你可以通过多种方式执行此操作:
- 在主线程中使用
Thread.join()
以阻塞方式等待每个线程完成,或者 - 以轮询方式(通常不鼓励使用)检查
Thread.isAlive()
,等待每个线程完成,或者 - 非常规的,对于每个有问题的线程,调用
setUncaughtExceptionHandler
来调用对象中的方法,并对每个线程进行编程以在完成时抛出未捕获的Exception
,或者 - 使用
java.util.concurrent
中的锁或同步器或机制,或者 - 更传统的做法是,在主线程中创建一个侦听器,然后对每个线程进行编程以告知侦听器它们已完成。
如何实施想法5?好吧,一种方法是首先创建一个接口:
public interface ThreadCompleteListener { void notifyOfThreadComplete(final Thread thread);}然后创建以下类:
public abstract class NotifyingThread extends Thread { private final Set<ThreadCompleteListener> listeners = new CopyOnWriteArraySet<ThreadCompleteListener>(); public final void addListener(final ThreadCompleteListener listener) { listeners.add(listener); } public final void removeListener(final ThreadCompleteListener listener) { listeners.remove(listener); } private final void notifyListeners() { for (ThreadCompleteListener listener : listeners) { listener.notifyOfThreadComplete(this); } } @Override public final void run() { try { doRun(); } finally { notifyListeners(); } } public abstract void doRun();}然后你的每个线程都将扩展
NotifyingThread,而不是实现
run()它将实现
doRun()。因此,完成后,他们将自动通知任何等待通知的人。
最后,在你的主类(启动所有线程(或至少等待通知的对象)的主类)中,将该类修改为
implement ThreadCompleteListener创建每个线程后立即将其自身添加到侦听器列表中:
NotifyingThread thread1 = new oneOfYourThreads();thread1.addListener(this); // add ourselves as a listenerthread1.start();// Start the Thread
然后,在每个线程退出时,
notifyOfThreadComplete将使用刚刚完成(或崩溃)的Thread实例调用你的方法。
需要注意的是更好的将
implements Runnable,而不是
extends Thread用于
NotifyingThread为延长线为新的代码通常气馁。但是,我正在编码你的问题。如果你更改NotifyingThread要实现的类,
Runnable则必须更改一些管理线程的代码,这非常简单。



