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

use*_*471 8 java multithreading mina

我们已经编写了一个控制台应用程序(将用作服务),它启动了几个工作线程来处理通过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)
Run Code Online (Sandbox Code Playgroud)

我们目前使用以下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)
Run Code Online (Sandbox Code Playgroud)

操作系统是ubuntu 14.04 LTS.

我对此行为一无所知,我希望能提供一些有关如何进一步调查此问题的提示.

附加信息

我按照建议生成了一个Full thread dump.四个线程在等待:

"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)
Run Code Online (Sandbox Code Playgroud)

有人可以证实,我应该调查pool-2-thread-1?我不确定如何解释结果.

解决方案 最后,对acceptor.dispose(MINA)的调用就行了......

Pet*_*rey 5

我的猜测是你创建了一个作为非守护进程运行的ExecutorService.这意味着如果你没有shutdown()这个池,它将保持应用程序运行,直到它正常地停止线程(因为它已经使用了几分钟)

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

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

pool-2-thread-1不是我们故意创建的

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

您可以通过使用强制非系统线程死亡System.exit(0); 这是不理想的,因为线程可能正在做有用的工作,如果它们由于一个充分的理由而成为非守护进程,但如果线程是由第三方库启动的,它可能是你最简单的选择.


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

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

另一种选择是修改Thread类以包含它创建(或启动)的位置的堆栈跟踪.您可以通过构建自己的版本并将其预先挂起到引导类路径来完成此操作.

  • @ user331471 我想 mina 有一种方法,您应该运行它来清理线程池等所有资源,而您没有运行它。 (2认同)