应用程序需要很长时间才能终止

Application takes very long to terminate

我们编写了一个控制台应用程序(将用作服务),它启动多个工作线程来处理通过 mina 传入的请求。当在特定网络端口上接收到停止信号时,应用程序离开主循环。这是停止服务的预期方式。这工作得很好,但是当收到停止信号时,应用程序的进程不会立即终止(最多需要 5 分钟)。我们通过日志消息验证了 main 函数已按预期快速离开,并且应用程序创建的所有线程也已终止。但是应用程序一直在 运行.

在离开主函数之前仍然运行的线程是:

Signal Dispatcher (java.lang.Thread)
Finalizer (java.lang.ref.Finalizer$FinalizerThread)
Abandoned connection cleanup thread (com.mysql.jdbc.AbandonedConnectionCleanupThread)
main (java.lang.Thread)
pool-2-thread-1 (java.lang.Thread)
Reference Handler (java.lang.ref.Reference$ReferenceHandler)

我们目前使用以下 java 版本:

java version "1.7.0_80"
Java(TM) SE Runtime Environment (build 1.7.0_80-b15)
Java HotSpot(TM) 64-Bit Server VM (build 24.80-b11, mixed mode)

操作系统是ubuntu 14.04 LTS。

我对这种行为一无所知,我希望得到一些关于如何进一步调查该问题的提示。

附加信息

我已经按照建议制作了完整的线程转储。四个线程正在等待:

"pool-2-thread-1" prio=10 tid=0x00007fd7fc51f000 nid=0x16200 waiting on condition [0x00007fd800318000]
   java.lang.Thread.State: TIMED_WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x00000000cceaf660> (a java.util.concurrent.SynchronousQueue$TransferStack)
    at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:226)
    at java.util.concurrent.SynchronousQueue$TransferStack.awaitFulfill(SynchronousQueue.java:460)
    at java.util.concurrent.SynchronousQueue$TransferStack.transfer(SynchronousQueue.java:359)
    at java.util.concurrent.SynchronousQueue.poll(SynchronousQueue.java:942)
    at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1068)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:745)

"Abandoned connection cleanup thread" daemon prio=10 tid=0x00007fd7fc23d800 nid=0x161e2 in Object.wait() [0x00007fd800cbb000]
   java.lang.Thread.State: TIMED_WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0x00000000dc2af720> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)
    - locked <0x00000000dc2af720> (a java.lang.ref.ReferenceQueue$Lock)
    at com.mysql.jdbc.AbandonedConnectionCleanupThread.run(AbandonedConnectionCleanupThread.java:41)

"Finalizer" daemon prio=10 tid=0x00007fd7fc066000 nid=0x161d6 in Object.wait() [0x00007fd801bd6000]
   java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0x00000000dc03c060> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:135)
    - locked <0x00000000dc03c060> (a java.lang.ref.ReferenceQueue$Lock)
    at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:151)
    at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)

"Reference Handler" daemon prio=10 tid=0x00007fd7fc064000 nid=0x161d5 in Object.wait() [0x00007fd801cd7000]
   java.lang.Thread.State: WAITING (on object monitor)
    at java.lang.Object.wait(Native Method)
    - waiting on <0x00000000dc03c108> (a java.lang.ref.Reference$Lock)
    at java.lang.Object.wait(Object.java:503)
    at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:133)
    - locked <0x00000000dc03c108> (a java.lang.ref.Reference$Lock)

有人可以确认我应该调查 pool-2-thread-1 吗?我不确定如何解释结果。

解决方法 最后调用 acceptor.dispose (MINA) 成功了...

我猜你已经创建了一个 运行 作为非守护进程的 ExecutorService。这意味着如果您不 shutdown() 这个池,它将保留应用程序 运行 直到它优雅地停止线程(因为它已经使用了几分钟)

您可以创建一个带有守护线程的 ExecutorService,以明确应用程序不需要等待此线程池停止。 (或者你可以明确地关闭它)

String poolName = ....
exec = Executors.newCachedThreadPool(r -> {
    Thread t = new Thread(r, poolName);
    t.setDaemon(true);
    return t;
});

pool-2-thread-1 is nothing that we created intentionally

这可以由库创建,但它遵循 ExecutorService 的形式。注意:它是 pool-2.. 表示它不是应用程序创建的第一个池。

您可以使用 System.exit(0); 强制非系统线程终止,这并不理想,因为如果出于充分的理由将线程设置为非守护进程,线程可能会做有用​​的工作,但如果线程是由第 3 方库启动,它可能是您最简单的选择。


您可以尝试跟踪所有线程的创建位置。一种方法是使用调试器断点 ThreadPoolExecutor 的构造函数或任何其他关键方法,这些方法将向您显示池的创建位置。

或者您可以使用具有分配跟踪功能的内存分析器。然后查看每个 Thread 对象的创建位置。

另一种选择是修改线程 class 以包含其创建(或启动)位置的堆栈跟踪。您可以通过构建自己的版本并将其预先挂起到引导程序来实现此目的 class路径。