Open
Description
首先感谢您使用 DynamicTp,如果对项目有任何疑问需要解答,请按照下述模板提问,建议使用 Markdown 语法。
使用方面
问题背景
public Object doGet() {
ExecutorService threadPool1 = new ThreadPoolExecutor(10, 10, 0L, TimeUnit.MILLISECONDS, new ArrayBlockingQueue<>(100));
CompletableFuture cf1 = CompletableFuture.supplyAsync(() -> {
//do sth
return CompletableFuture.supplyAsync(() -> {
System.out.println("child");
return "child";
}, threadPool1).join();//子任务
}, threadPool1);
return cf1.join();
}
如上代码块所示,doGet方法第三行通过supplyAsync向threadPool1请求线程,并且内部子任务又向threadPool1请求线程。threadPool1大小为10,当同一时刻有10个请求到达,则threadPool1被打满,子任务请求线程时进入阻塞队列排队,但是父任务的完成又依赖于子任务,这时由于子任务得不到线程,父任务无法完成。主线程执行cf1.join()进入阻塞状态,并且永远无法恢复。
文章中也提到了解决方案:为了修复该问题,需要将父任务与子任务做线程池隔离,两个任务请求不同的线程池,避免循环依赖导致的阻塞。
具体问题:除了线程池隔离这样的人为约定,有没有办法通过代码实现【线程池循环引用】的自动监控?
尝试扩展了下 ExecutorAware
,在execute
方法里面,将提交任务的线程所对应的线程池名称记录下来并绑定到任务上,然后在beforeExecute
中,获取当前实际执行的线程池的名称,和任务中绑定的名称做对比,如果相等,则认为发生了【线程池循环引用】。
这样的方式,解决父子任务【AA】场景是没有问题的,但是如果是【ABA】这样的方式就无能为力了(如下),想知道这个问题有办法解决吗?
private void test() {
DtpRegistry.getDtpExecutor("dtp1").submit(() -> {
System.out.println("--------------------");
System.out.println("in dtp1");
System.out.println("--------------------");
DtpRegistry.getDtpExecutor("dtp2").submit(() -> {
System.out.println("--------------------");
System.out.println("in dtp2");
System.out.println("--------------------");
DtpRegistry.getDtpExecutor("dtp1").submit(() -> {
System.out.println("--------------------");
System.out.println("in dtp1");
System.out.println("--------------------");
});
});
});
}