前几天,在帮同事排查一个线上偶发的线程池错误
逻辑很简单,线程池执行了一个带结果的异步任务。但是最近有偶发的报错:
java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@a5acd19 rejected from java.util.concurrent.ThreadPoolExecutor@30890a38[Terminated, pool size = 0, active threads = 0, queued tasks = 0, completed tasks = 0]
本文中的模拟代码已经问题都是在 HotSpot java8 (1.8.0_221) 版本下模拟 & 出现的
下面是模拟代码,通过 Executors.newSingleThreadExecutor 创建一个单线程的线程池,然后在调用方获取 Future 的结果
复制代码
publicclassThreadPoolTest{ publicstaticvoidmain(String[] args){ final ThreadPoolTest threadPoolTest =newThreadPoolTest(); for(inti =0; i <8; i++) { newThread(newRunnable() { @Override publicvoidrun() { while(true) { Future<String>future= threadPoolTest.submit(); try{ Strings =future.get(); }catch(InterruptedException e) { e.printStackTrace(); }catch(ExecutionException e) { e.printStackTrace(); }catch(Error e) { e.printStackTrace(); } } } }).start(); } // 子线程不停 gc,模拟偶发的 gc newThread(newRunnable() { @Override publicvoidrun() { while(true) { System.gc(); } } }).start(); } /** * 异步执行任务 * @return */ publicFuture<String> submit() { // 关键点,通过 Executors.newSingleThreadExecutor 创建一个单线程的线程池 ExecutorService executorService = Executors.newSingleThreadExecutor(); FutureTask<String> futureTask =newFutureTask(newCallable() { @Override publicObject call() throws Exception { Thread.sleep(50); returnSystem.currentTimeMillis() +""; } }); executorService.execute(futureTask); returnfutureTask; } }
第一个思考的问题是:线程池为什么关闭了,代码中并没有手动关闭的地方。看一下 Executors.newSingleThreadExecotor
的源码实现:
复制代码
publicstaticExecutorServicenewSingleThreadExecutor() { returnnewFinalizableDelegatedExecutorService (newThreadPoolExecutor(1,1, 0L, TimeUnit.MILLISECONDS, newLinkedBlockingQueue<Runnable>())); }
这里创建的实际上是一个 FinalizableDelegatedExecutorService
,这个包装类重写了 finalize
函数,也就是说这个类会在被 GC 回收之前,先执行线程池的 shutdown 方法。
问题来了, GC 只会回收不可达(unreachable)的对象
,在 submit
函数的栈帧未执行完出栈之前, executorService
应该是可达的才对。
对于此问题,先抛出结论:
finalize
也可能会被执行 oracle jdk 文档中有一段关于 finalize 的介绍:
https://docs.oracle.com/javas …
A reachable object is any object that can be accessed in any potential continuing computation from any live thread. Optimizing transformations of a program can be designed that reduce the number of objects that are reachable to be less than those which would naively be considered reachable. For example, a Java compiler or code generator may choose to set a variable or parameter that will no longer be used to null to cause the storage for such an object to be potentially reclaimable sooner.
也就是说,在 jvm 的优化下,可能会出现对象不可达之后被提前置空并回收的情况
举个例子来验证一下(摘自 https://stackoverflow.com/questions/24376768/can-java-finalize-an-object-when-it-is-still-in-scope ):
复制代码
classA{ @Overrideprotectedvoidfinalize() { System.out.println(this+" was finalized!"); } publicstaticvoidmain(String[] args) throws InterruptedException { A a = new A(); System.out.println("Created "+ a); for(inti =0; i <1_000_000_000; i++) { if(i %1_000_00 ==0) System.gc(); } System.out.println("done."); } } // 打印结果 CreatedA@1be6f5c3 A@1be6f5c3 was finalized!//finalize 方法输出 done.
从例子中可以看到,如果 a 在循环完成后已经不再使用了,则会出现先执行 finalize 的情况;虽然从对象作用域来说,方法没有执行完,栈帧并没有出栈,但是还是会被提前执行。
现在来增加一行代码,在最后一行打印对象 a,让编译器 / 代码生成器认为后面有对象 a 的引用
复制代码
... System.out.println(a); // 打印结果 CreatedA@1be6f5c3 done. A@1be6f5c3
从结果上看,finalize 方法都没有执行(因为 main 方法执行完成后进程直接结束了),更不会出现提前 finalize 的问题了
基于上面的测试结果,再测试一种情况,在循环之前先将对象 a 置为 null,并且在最后打印保持对象 a 的引用
复制代码
A a = new A(); System.out.println("Created "+ a); a =null;// 手动置 null for(inti =0; i <1_000_000_000; i++) { if(i %1_000_00 ==0) System.gc(); } System.out.println("done."); System.out.println(a); // 打印结果 CreatedA@1be6f5c3 A@1be6f5c3 was finalized! done. null
从结果上看,手动置 null 的话也会导致对象被提前回收,虽然在最后还有引用,但此时引用的也是 null 了
现在再回到上面的线程池问题,根据上面介绍的机制,在分析没有引用之后,对象会被提前 finalize
可在上述代码中,return 之前明明是有引用的 executorService.execute(futureTask)
,为什么也会提前 finalize 呢?
猜测可能是由于在 execute 方法中,会调用 threadPoolExecutor,会创建并启动一个新线程,这时会发生一次主动的线程切换,导致在活动线程中对象不可达
结合上面 Oracle Jdk 文档中的描述“可达对象 (reachable object) 是可以从任何活动线程的任何潜在的持续访问中的任何对象”,可以认为可能是因为一次显示的线程切换,对象被认为不可达了,导致线程池被提前 finalize 了
下面来验证一下猜想:
复制代码
// 入口函数 publicclassFinalizedTest{ publicstaticvoidmain(String[] args){ finalFinalizedTest finalizedTest =newFinalizedTest(); for(inti =0; i <8; i++) { newThread(newRunnable() { @Override publicvoidrun(){ while(true) { TFutureTask future = finalizedTest.submit(); } } }).start(); } newThread(newRunnable() { @Override publicvoidrun(){ while(true) { System.gc(); } } }).start(); } publicTFutureTasksubmit(){ TExecutorService TExecutorService = Executors.create(); TExecutorService.execute(); returnnull; } } //Executors.java,模拟 juc 的 Executors publicclassExecutors{ /** * 模拟 Executors.createSingleExecutor *@return */ publicstaticTExecutorServicecreate(){ returnnewFinalizableDelegatedTExecutorService(newTThreadPoolExecutor()); } staticclassFinalizableDelegatedTExecutorServiceextendsDelegatedTExecutorService{ FinalizableDelegatedTExecutorService(TExecutorService executor) { super(executor); } /** * 析构函数中执行 shutdown,修改线程池状态 *@throwsThrowable */ @Override protectedvoidfinalize()throwsThrowable{ super.shutdown(); } } staticclassDelegatedTExecutorServiceextendsTExecutorService{ protectedTExecutorService e; publicDelegatedTExecutorService(TExecutorService executor){ this.e = executor; } @Override publicvoidexecute(){ e.execute(); } @Override publicvoidshutdown(){ e.shutdown(); } } } //TThreadPoolExecutor.java,模拟 juc 的 ThreadPoolExecutor publicclassTThreadPoolExecutorextendsTExecutorService{ /** * 线程池状态,false:未关闭,true 已关闭 */ privateAtomicBoolean ctl =newAtomicBoolean(); @Override publicvoidexecute(){ // 启动一个新线程,模拟 ThreadPoolExecutor.execute newThread(newRunnable() { @Override publicvoidrun(){ } }).start(); // 模拟 ThreadPoolExecutor,启动新建线程后,循环检查线程池状态,验证是否会在 finalize 中 shutdown // 如果线程池被提前 shutdown,则抛出异常 for(inti =0; i <1_000_000; i++) { if(ctl.get()){ thrownewRuntimeException("reject!!!["+ctl.get()+"]"); } } } @Override publicvoidshutdown(){ ctl.compareAndSet(false,true); } }
执行若干时间后报错:
复制代码
Exception in thread"Thread-1"java.lang.RuntimeException: reject!!![true
从错误上来看,“线程池”同样被提前 shutdown 了,那么一定是由于新建线程导致的吗?
下面将新建线程修改为 Thread.sleep
测试一下:
复制代码
//TThreadPoolExecutor.java,修改后的 execute 方法 publicvoidexecute(){ try{ // 显式的 sleep 1 ns,主动切换线程 TimeUnit.NANOSECONDS.sleep(1); }catch(InterruptedException e) { e.printStackTrace(); } // 模拟 ThreadPoolExecutor,启动新建线程后,循环检查线程池状态,验证是否会在 finalize 中 shutdown // 如果线程池被提前 shutdown,则抛出异常 for(inti =0; i <1_000_000; i++) { if(ctl.get()){ thrownewRuntimeException("reject!!!["+ctl.get()+"]"); } } }
执行结果一样是报错
复制代码
Exception in thread"Thread-3"java.lang.RuntimeException: reject!!![true]
虽然 GC 只会回收不可达 GC ROOT 的对象,但是在编译器(没有明确指出,也可能是 JIT)/ 代码生成器的优化下,可能会出现对象提前置 null,或者线程切换导致的“提前对象不可达”的情况。
所以如果想在 finalize 方法里做些事情的话,一定在最后显示的引用一下对象(toString/hashcode 都可以),保持对象的可达性(reachable)
上面关于线程切换导致的对象不可达,没有官方文献的支持,只是个人一个测试结果,如有问题欢迎指出
Executors.newSingleThreadExecutor
的实现里通过 finalize 来自动关闭线程池的做法是有 Bug 的,在经过优化后可能会导致线程池的提前 shutdown,从而导致异常。 线程池的这个问题,在 JDK 的论坛里也是一个公开但未解决状态的问题 https://bugs.openjdk.java.net/browse/JDK-8145304 。
不过在 JDK11 下,该问题已经被修复:
复制代码
JUC Executors.FinalizableDelegatedExecutorService publicvoidexecute(Runnable command){ try{ e.execute(command); }finally{ reachabilityFence(this); } }
https://mp.weixin.qq.com/s/idDL9uJJb5KKOFY5tLlyKw