上篇文章 shutdownhook- java 优雅停机解决方案 提到应用停机时需要释放资源,关闭连接。对于一些定时任务或者网络请求服务将会使用线程池,当应用停机时需要正确安全的关闭线程池,如果处理不当,可能造成数据丢失,业务请求结果不正确等问题。
关闭线程池我们可以选择什么都不做,jvm 关闭时自然的会清除线程池对象。当然这么做,存在很大的弊端,线程池中正在执行执行的线程以及队列中还未执行任务将会变得极不可控。所以我们需要想办法控制到这些未执行的任务以及正在执行的线程。
线程池 api 提供两个主动关闭的方法 threadpoolexecutor#shutdownnow
与 threadpoolexecutor#shutdown
,这两个方法都可以用于关闭线程池,但是具体效果却不太一样。
在说线程池关闭方法之前,我们先了解线程池状态。
线程池状态关系图如下:
从上图我们看到线程池总共存在 5 种状态,分别为:
terminated()
钩子方法。terminated()
钩子方法之后。当我们执行 threadpoolexecutor#shutdown
方法将会使线程池状态从 running 转变为 shutdown。而调用 threadpoolexecutor#shutdownnow
之后线程池状态将会从 running 转变为 stop。从上面的图上还可以看到,当线程池处于 shutdown,我们还是可以继续调用 threadpoolexecutor#shutdownnow
方法,将其状态转变为 stop 。
上面我们知道线程池状态,这里先说说 shutdown
方法。shutdown
方法源码比较简单,能比较直观理解其调用逻辑。
shutdown
方法源码:
public void shutdown() { final reentrantlock mainlock = this.mainlock; mainlock.lock(); try { // 检查权限 checkshutdownaccess(); // 设置线程池状态 advancerunstate(shutdown); // 中断空闲线程 interruptidleworkers(); // 钩子函数,主要用于清理一些资源 onshutdown(); } finally { mainlock.unlock(); } tryterminate(); }
shutdown
方法首先加锁,其次先检查系统安装状态。接着就会将线程池状态变为 shutdown,在这之后线程池不再接受提交的新任务。此时如果还继续往线程池提交任务,将会使用线程池拒绝策略响应,默认情况下将会使用 threadpoolexecutor.abortpolicy
,抛出 rejectedexecutionexception
异常。
interruptidleworkers
方法只会中断空闲的线程,不会中断正在执行任务的的线程。空闲的线程将会阻塞在线程池的阻塞队列上。
线程池构造参数需要指定 coresize(核心线程池数量),maximumpoolsize(最大的线程池数量),keepalivetime(多余空闲线程等待时间),unit(时间单位),workqueue(阻塞队列)。
当调用线程池的 execute
方法,线程池工作流程如下:
工作流程图如下:
当线程池处于第二步时,线程将会使用 workqueue#take
获取队头的任务,然后完成任务。如果工作队列一直没任务,由于队列为阻塞队列,workqueue#take
将会阻塞线程。
threadpoolexecutor#shutdownnow
源码如下:
public list<runnable> shutdownnow() { list<runnable> tasks; final reentrantlock mainlock = this.mainlock; mainlock.lock(); try { // 检查状态 checkshutdownaccess(); // 将线程池状态变为 stop advancerunstate(stop); // 中断所有线程,包括工作线程以及空闲线程 interruptworkers(); // 丢弃工作队列中存量任务 tasks = drainqueue(); } finally { mainlock.unlock(); } tryterminate(); return tasks; }
shutdownnow
方法将会把线程池状态设置为 stop,然后中断所有线程,最后取出工作队列中所有未完成的任务返回给调用者。
对比 shutdown
方法,shutdownnow
方法比较粗暴,直接中断工作线程。不过这里需要注意,中断线程并不代表线程立刻结束。这里需要线程主动配合线程中断响应。
线程中断机制:
thread#interrupt
只是设置一个中断标志,不会立即中断正常的线程。如果想让中断立即生效,必须在线程 内调用thread.interrupted()
判断线程的中断状态。
对于阻塞的线程,调用中断时,线程将会立刻退出阻塞状态并抛出interruptedexception
异常。所以对于阻塞线程需要正确处理interruptedexception
异常。
线程池 shutdown
与 shutdownnow
方法都不会主动等待执行任务的结束,如果需要等到线程池任务执行结束,需要调用 awaittermination
主动等待任务调用结束。
调用方法如下:
threadpool.shutdown(); try { while (!threadpool.awaittermination(60,timeunit.seconds)){ system.out.println("线程池任务还未执行结束"); } } catch (interruptedexception e) { e.printstacktrace(); }
如果线程池任务执行结束,awaittermination
方法将会返回 true
,否则当等待时间超过指定时间后将会返回 false
。
如果需要使用这种进制,建议在上面的基础上增加一定重试次数。这个真的很重要!!!
回顾上面线程池状态关系图,我们可以知道处于 shutdown 的状态下的线程池依旧可以调用 shutdownnow
。所以我们可以结合 shutdown
, shutdownnow
,awaittermination
,更加优雅关闭线程池。
threadpool.shutdown(); // disable new tasks from being submitted // 设定最大重试次数 try { // 等待 60 s if (!threadpool.awaittermination(60, timeunit.seconds)) { // 调用 shutdownnow 取消正在执行的任务 threadpool.shutdownnow(); // 再次等待 60 s,如果还未结束,可以再次尝试,或则直接放弃 if (!threadpool.awaittermination(60, timeunit.seconds)) system.err.println("线程池任务未正常执行结束"); } } catch (interruptedexception ie) { // 重新调用 shutdownnow threadpool.shutdownnow(); }
文章首发于
欢迎关注我的公众号:程序通事,获得日常干货推送。如果您对我的专题内容感兴趣,也可以关注我的博客:
如对本文有疑问, 点击进行留言回复!!
sap cloud platform destination的配置
springcloud中feign调用处理mybatis-plus Ipage反序列化问题。
Flume 史上最全面的大数据学习第十篇(一) 别再说不知道flume是什么了
网友评论