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

  • Z时代
  • 2024-01-10
  • 分类：问答

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

每个线程执行完毕后，如何获得通知？

有没有办法知道一个（或全部）线程是否已完成或仍在执行？

回答：

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

  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则必须更改一些管理线程的代码，这非常简单。

以上是 Java如何知道其他线程是否已完成？ 的全部内容， 来源链接： utcz.com/qa/426093.html

回到顶部