本文旨在解决Java多线程编程中使用`Future.get()`方法时，遇到的结果为null的问题。通过分析代码示例，解释了导致该问题的原因，并提供了使用StringBuilder累计读取结果的解决方案，确保从API接口获取的数据能够正确返回。
在Java多线程编程中，Future接口用于表示异步计算的结果。当你使用ExecutorService提交任务时，会返回一个Future对象，你可以通过调用Future.get()方法来获取任务的执行结果。然而，有时Future.get()会返回null，这通常是因为任务的返回值在某些情况下没有正确设置。
问题分析
在提供的代码示例中，问题出在StyleThreadDemo类的callApi()方法中。该方法通过HttpURLConnection从API接口读取数据，并将读取到的数据赋值给output变量。关键代码如下：
立即学习“Java免费学习笔记（深入）”；
while ((output = br.readLine()) != null) { System.out.println("result "+ n );}return output;
这段代码使用BufferedReader逐行读取API的响应，并在循环中打印一些信息。但是，当循环结束时，output变量的值为null，因为循环的退出条件是br.readLine()返回null。因此，callApi()方法最终返回null，导致Future.get()也返回null。
解决方案
Skybox AI
一键将涂鸦转为360°无缝环境贴图的AI神器
140 查看详情 
为了解决这个问题，我们需要在循环中累积读取到的数据，并在循环结束后返回累积的结果。可以使用StringBuilder来实现：
public String callApi() throws Exception { StringBuilder sb = new StringBuilder(); String output = null; try { URL url = new URL("https://api.publicapis.org/entries"); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); conn.setRequestProperty("Accept", "application/json"); if (conn.getResponseCode() != 200) { throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode()); } BufferedReader br = new BufferedReader(new InputStreamReader( (conn.getInputStream()))); System.out.println("Data starting coming .... n"); while ((output = br.readLine()) != null) { System.out.println("result "+ n ); sb.append(output); } conn.disconnect(); }catch(Exception e) { e.printStackTrace(); } return sb.toString();}
在这个修改后的版本中，我们使用StringBuilder对象sb来累积从BufferedReader读取的每一行数据。在循环结束后，我们将StringBuilder对象转换为字符串并返回。这样，Future.get()方法就可以获取到完整的API响应数据。
完整代码示例
import java.io.BufferedReader;import java.io.InputStreamReader;import java.net.HttpURLConnection;import java.net.URL;import java.util.ArrayList;import java.util.List;import java.util.concurrent.*;class StyleThreadDemo implements Callable{ private Integer n; public StyleThreadDemo(int a){ this.setN(a); } public String callApi() throws Exception { StringBuilder sb = new StringBuilder(); String output=null; try { URL url = new URL("https://api.publicapis.org/entries"); HttpURLConnection conn = (HttpURLConnection) url.openConnection(); conn.setRequestMethod("GET"); conn.setRequestProperty("Accept", "application/json"); if (conn.getResponseCode() != 200) { throw new RuntimeException("Failed : HTTP error code : " + conn.getResponseCode()); } BufferedReader br = new BufferedReader(new InputStreamReader( (conn.getInputStream()))); System.out.println("Data starting coming .... n"); while ((output = br.readLine()) != null) { System.out.println("result "+ n ); sb.append(output); } conn.disconnect(); }catch(Exception e) { e.printStackTrace(); } return sb.toString(); } @Override public String call() throws Exception { String s=callApi(); return s; } public Integer getN() { return n; } public void setN(Integer n) { this.n = n; }}public class StyleThread { public static void shutdownAndAwaitTermination(ExecutorService executorService) { executorService.shutdown(); try { if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) { executorService.shutdownNow(); } } catch (InterruptedException ie) { executorService.shutdownNow(); Thread.currentThread().interrupt(); } } public static void main(String[] args) throws Exception { StyleThread styleThread = new StyleThread(); ExecutorService pool = Executors.newFixedThreadPool(30); int n = 5; // Number of threads List tasks= new ArrayList();// List<Future> futures = new ArrayList(); for (int i = 0; i < n; i++) {// Future result= pool.submit(new StyleThreadDemo(i));// futures.add(result); tasks.add(new StyleThreadDemo(i)); System.out.println("task added "+i); } List<Future> futures=pool.invokeAll(tasks); shutdownAndAwaitTermination(pool); for (Future f : futures) { System.out.println("printing :"+f.get()); } }}
注意事项
异常处理： 在实际应用中，需要更完善的异常处理机制，例如，在读取API响应时，应该处理IOException等异常。资源释放： 确保在使用完HttpURLConnection和BufferedReader后，正确关闭它们，释放资源。字符编码： 在读取API响应时，需要注意字符编码问题，确保能够正确解析API返回的数据。
总结
当使用Future.get()方法获取结果为null时，需要仔细检查任务的返回值是否正确设置。对于从输入流读取数据的情况，可以使用StringBuilder累积读取到的数据，确保能够返回完整的结果。同时，要注意异常处理和资源释放，保证程序的稳定性和可靠性。通过以上方法，可以有效地解决Java多线程编程中使用Future.get()方法时遇到的结果为null的问题。
以上就是Java多线程Future.get()方法获取结果为null的解决方案的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/935841.html
微信扫一扫 
支付宝扫一扫 
