线程池-一种引起死锁现象的使用方式

一时失言乱红尘 2023-10-07 23:09 19阅读 0赞

`异步并发场景下，父子任务使用同一个线程池，将可能引起死锁现象。`  
代码如下：

public class ThreadPoolBlockedDemo {
        
        public static void main(String[] args) throws InterruptedException {
        
            ExecutorService executorPool = Executors.newFixedThreadPool(3);
            List<CompletableFuture> futureList = new ArrayList<CompletableFuture>();
            for (int i = 0; i < 3; i++) {
        
                CompletableFuture<Void> fatherFuture = CompletableFuture.runAsync(new Runnable() {
        
                    @Override
                    public void run() {
        
                        try {
        
                            TimeUnit.SECONDS.sleep(1);
                        } catch (InterruptedException e) {
        
                            throw new RuntimeException(e);
                        }
                        System.out.println("父任务执行了");
                        CompletableFuture<Void> childFuture = CompletableFuture.runAsync(new Runnable() {
        
                            @Override
                            public void run() {
        
                                System.out.println("子任务执行了");
                            }
                        }, executorPool);
                        childFuture.join();
                    }
                }, executorPool);
                futureList.add(fatherFuture);
            }
            CompletableFuture.allOf(futureList.toArray(new CompletableFuture[0])).join();
            executorPool.shutdown();
        }
    }

#### 分析 ####

*  该代码中创建了3个父任务，每个父任务都在线程池中运行。
 *  线程池的大小为3，因此可以同时执行3个父任务。
 *  每个父任务在执行时，都创建了一个子任务，并在线程池中排队等待执行。
 *  但是，在父任务中，用 childFuture.join() 方法等待子任务执行完成，而没有考虑子任务的执行需要线程池的参与，
 *  因此导致父任务永远等待子任务的执行，线程池中的子任务也永远不会被执行，从而导致线程阻塞和死锁。
 *  因此，该代码存在线程死锁的情况。