记一次使用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
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。 如若内容造成侵权/违法违规/事实不符,请联系我的编程经验分享网邮箱:veading@qq.com进行投诉反馈,一经查实,立即删除!