我有一个名为的方法的对象,该方法StartDownload()启动三个线程。
StartDownload()
每个线程执行完毕后,如何获得通知?
有没有办法知道一个(或全部)线程是否已完成或仍在执行?
你可以通过多种方式执行此操作:
Thread.join()
Thread.isAlive()
setUncaughtExceptionHandler
Exception
java.util.concurrent
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()。因此,完成后,他们将自动通知任何等待通知的人。
NotifyingThread
run()
doRun()
最后,在你的主类(启动所有线程(或至少等待通知的对象)的主类)中,将该类修改为implement ThreadCompleteListener创建每个线程后立即将其自身添加到侦听器列表中:
implement ThreadCompleteListener
NotifyingThread thread1 = new OneOfYourThreads(); thread1.addListener(this); // add ourselves as a listener thread1.start(); // Start the Thread
然后,在每个线程退出时,notifyOfThreadComplete将使用刚刚完成(或崩溃)的Thread实例调用你的方法。
notifyOfThreadComplete
需要注意的是更好的将implements Runnable,而不是extends Thread用于NotifyingThread为延长线为新的代码通常气馁。但是,我正在编码你的问题。如果你更改NotifyingThread要实现的类,Runnable则必须更改一些管理线程的代码,这非常简单。
implements Runnable
extends Thread
Runnable