前言
在Spring Boot中有一個注釋@Async，可以幫助開發人員開發并發應用程序。但使用此功能非常棘手。在本博客中，我們將了解如何將此功能與CompletableFuture一起使用。我認為你已經知道關于CompletableFuture的基礎，所以我不會在這里重復這個概念。
首先，您需要使用@EnableAsync來注釋您的應用程序類，這個注釋告訴Spring查找使用@Async注釋的方法并在單獨的執行程序中運行它們。
@SpringBootApplication@EnableAsyncpublic class App { RestTemplate public static void main(String[] args) { SpringApplication.run(App.class, args); }}如果您查看有關使用CompletableFuture和@Async的Spring Boot示例，您會注意到他們使用此功能的方式基于REST請求，在我看來，我相信，它有點受限，它不會給你在其他情況下如何使用此功能的線索。例如，如果你有一個長期運行的任務，你會怎么做？
// Source : https://spring.io/guides/gs/async-method/package hello;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.boot.web.client.RestTemplateBuilder;import org.springframework.scheduling.annotation.Async;import org.springframework.stereotype.Service;import org.springframework.web.client.RestTemplate;import java.util.concurrent.CompletableFuture;@Servicepublic class GitHubLookupService { private static final Logger logger = LoggerFactory.getLogger(GitHubLookupService.class); private final RestTemplate restTemplate; public GitHubLookupService(RestTemplateBuilder restTemplateBuilder) { this.restTemplate = restTemplateBuilder.build(); } @Async public CompletableFuture<User> findUser(String user) throws InterruptedException { logger.info("Looking up " + user); String url = String.format("https://api.github.com/users/%s", user); User results = restTemplate.getForObject(url, User.class); // Artificial delay of 1s for demonstration purposes Thread.sleep(1000L); return CompletableFuture.completedFuture(results); }}在FindUser（String user）中，它在主線程中使用CompletableFuture，此方法的主要任務是使用RestTemplate從github獲取數據，功能是“執行HTTP請求的同步客戶端”。如何使用長時間運行的任務，如調用網絡功能，如從REST端點ping服務器？在這種情況下，您需要定制CompletableFuture。你不能簡單地調用：
return CompletableFuture.completedFuture(results);
如何使用CompletableFuture
要在代碼中使用@Async，您的方法必須返回Future或CompletableFuture，看一下下面的例子：
@Async public CompletableFuture<Boolean> isServerAlive(String ip) { CompletableFuture<Boolean> future = new CompletableFuture<Boolean>(){ @Override public Boolean get() throws InterruptedException, ExecutionException { InetAddress address = null; try { address = InetAddress.getByName(ip); return address.isReachable(1000); } catch (UnknownHostException e) { e.printStackTrace(); return false; } catch (IOException e) { e.printStackTrace(); return false; } } }; return future;}在這個例子中，我重寫了get（）方法并返回CompletableFuture而沒有任何線程執行器，事實上我們要求Spring在不同的線程中執行@Async方法，但是我們不提供任何線程執行器，只有后臺工作者中運行就足夠了。
download source code from github
注意：在這個例子中，我決定在Spring Boot中使用一個網絡函數，僅僅是為了一個參數。但最好不要在REST端點中直接使用網絡功能，特別是當您希望立即獲得結果時。原因是：網絡功能是阻塞的，這意味著，如果你調用這個REST端點，您必須在端點等待獲取結果。強烈建議使用其他方法（如queue或push方法）（例如websocket）來調用阻塞函數。
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對VeVb武林網的支持。
新聞熱點
疑難解答
圖片精選
