成都企业网站建站中高端社交网站建设服务商

死锁（任务互相等待）

问题描述

任务向同一线程池提交子任务并等待其完成，导致线程池资源耗尽，形成死锁。

错误实现

• 线程池饱和：父任务占用唯一线程，子任务进入队列等待。
• 互相等待：父任务等待子任务完成，子任务因队列满无法执行。

public class DeadlockDemo {public static void main(String[] args) {ThreadPoolExecutor executor = new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS,new LinkedBlockingQueue<>());// 提交父任务executor.execute(() -> {System.out.println("父任务开始");Future<?> future = executor.submit(() -> {System.out.println("子任务开始");return "子任务结果";});try {future.get(); // 等待子任务完成（但线程池已满，子任务无法执行）} catch (Exception e) {e.printStackTrace();}System.out.println("父任务结束");});}
}

运行结果

父任务开始
（程序挂起，无后续输出）

正确实现

• 解耦任务依赖：避免同一线程池内任务相互等待。
• 使用独立线程池：父子任务由不同线程池处理。

public class DeadlockFixedDemo {public static void main(String[] args) {ThreadPoolExecutor parentExecutor =new ThreadPoolExecutor(1, 1, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>());ThreadPoolExecutor childExecutor =new ThreadPoolExecutor(2, 2, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>());// 提交父任务并获取FutureFuture<?> parentFuture = parentExecutor.submit(() -> {System.out.println("父任务开始");Future<?> childFuture = childExecutor.submit(() -> {System.out.println("子任务开始");return "子任务结果";});try {childFuture.get(); // 等待子任务完成} catch (Exception e) {e.printStackTrace();}System.out.println("父任务结束");});try {// 等待父任务完成parentFuture.get();} catch (InterruptedException | ExecutionException e) {e.printStackTrace();} finally {// 父任务完成后关闭线程池parentExecutor.shutdown();childExecutor.shutdown();}}
}

运行结果

父任务开始
子任务开始
父任务结束