记一次使用Future+ExecutorPool的多线程卡死问题

2023-12-28 12:43:41

使用带有返回值的线程池时,需要留意关闭线程池后,及时处理还在等待线程返回的逻辑

复现代码:

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class Demo {

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        List<Future> futures = new ArrayList<>();
        for (int i = 0; i < 10; i++) {
            futures.add(executorService.submit(new SubClass(i)));
        }
        // 这里的get()方法会等待【线程0】结束并拿到返回值
        System.out.println(futures.get(0).get());
        // 当【线程0】结束时我们强制关闭线程池
        executorService.shutdownNow();
        // 这时如果在程序的其他位置还在等待线程结束,就会导致程序卡死
        System.out.println(futures.get(8).get());
    }

文章来源:https://blog.csdn.net/qq_44880708/article/details/135265639
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。