使用带有返回值的线程池时,需要留意关闭线程池后,及时处理还在等待线程返回的逻辑
复现代码:
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());
}