一尘不染

Java如何知道其他线程是否已完成?

java

我有一个名为的方法的对象,该方法StartDownload()启动三个线程。

每个线程执行完毕后,如何获得通知?

有没有办法知道一个(或全部)线程是否已完成或仍在执行?


阅读 707

收藏
2020-03-03

共1个答案

一尘不染

你可以通过多种方式执行此操作:

  1. 在主线程中使用Thread.join()以阻塞方式等待每个线程完成,或者
  2. 以轮询方式(通常不鼓励使用)检查Thread.isAlive(),等待每个线程完成,或者
  3. 非常规的,对于每个有问题的线程,调用setUncaughtExceptionHandler来调用对象中的方法,并对每个线程进行编程以在完成时抛出未捕获的Exception,或者
  4. 使用java.util.concurrent中的锁或同步器或机制,或者
  5. 更传统的做法是,在主线程中创建一个侦听器,然后对每个线程进行编程以告知侦听器它们已完成。
    如何实施想法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 listener
thread1.start();           // Start the Thread

然后,在每个线程退出时,notifyOfThreadComplete将使用刚刚完成(或崩溃)的Thread实例调用你的方法。

需要注意的是更好的将implements Runnable,而不是extends Thread用于NotifyingThread为延长线为新的代码通常气馁。但是,我正在编码你的问题。如果你更改NotifyingThread要实现的类,Runnable则必须更改一些管理线程的代码,这非常简单。

2020-03-03