Java奇怪的线程终止

Question

我有一个运行多个线程的系统 - 我的主线程只是检查是否有作业要做，如果有，它会调用将执行它的子线程（notifyAll()） 。之后，子线程只是wait()，直到有一些新任务为止。

实际上，线程系统运行可靠，但是在较长的运行时间（3-5小时）之后，一些子线程在没有警告或错误的情况下就死掉了。他们只是一个接一个地退出——但同样只有 2-x 小时的时间范围。我使用 jconsole 来检查这种现象，哪些线程正在运行以及它们如何消失。

此外，主线程每秒都在执行，但子线程主要是 wait() ，根本不经常使用（因为测试环境中没有那么多任务）。

我能想到的唯一原因是，JVM 关闭子线程，因为它们不经常使用？

我将非常感谢您的帮助！

PS 所有线程都没有定义为守护进程，主线程工作正常！

编辑

感谢您的回答，但我实际上使用这个循环。

public void addTask (Task in_task) throws InterruptedException {
        synchronized (tasks) {
              while (tasks.size() == MAXIMUM_NUMBER_OF_TASKS) {
                   tasks.wait();
              }
              tasks.offer(in_task);
              tasks.notifyAll();
        }
}

我使用这个循环，以便只执行一些特殊数量的任务。

Answer 1

Object.wait() 的文档说：

与单参数版本一样，中断和虚假唤醒是可能的，并且此方法应始终在循环中使用：

 synchronized (obj) {
     while (<condition does not hold>)
         obj.wait();
     ... // Perform action appropriate to condition
 }

也许您没有遵循此建议并得到了虚假唤醒或中断？

Answer 2

您可以使用 java.util.concurrent.ThreadPoolExecutor。无论您是否能够修复此错误，这都可能是一个好主意。

Answer 3

我建议使用Executors之一来管理您的任务。您在子线程之一中丢失可能的错误或异常的可能性较小，因此它应该可以帮助您调试程序。子线程中发生的任何异常都将存储在 Future 对象中，并在调用 Future#get() 时作为 ExecutionException 重新抛出。

List<Future<Void>> taskResults = new ArrayList<Future<Void>>();
ExecutorService es = Executors.newFixedThreadPool(NUMBER_OF_THREADS);

while(!finished){
  //say you wait (blocking) for a new task here
  Callable<Void> task = getNextTask();

  //put the task into the pool
  Future<Void> result = es.submit(task);
  taskResults.add(result);
}

//3 hours later, set `finished` to true

//at the end check that no exceptions were thrown
for(Future<Void> result : taskResults){
  try{
    result.get();
  }catch(ExecutionException e){
    //there was an error
    e.getCause().printStackTrace();
  }catch(InterruptedException e){
    //irrelevant
  }
}

一般来说，java.util.concurrent 中的内容可以帮助您编写更健壮的多线程应用程序，而不必求助于 Object#wait() 和其他并发原语（当然，除非你正在学习）。

Answer 4

尝试在每个线程上设置一个未捕获的异常处理程序。
Thread 上有一个 setUncaughtExceptionHandler() 函数。实现 UncaughtExceptionHandler 接口并打印异常。

一般想法，但不要使用匿名类/方法：

thread.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler()
{
  public void uncaughtException(Thread t, Throwable e)
  {
    e.printStackTrace();
  }
});