का उद्देश्य क्या है CompletableFuture की पूरी विधि है?

पूर्ण() के बराबर है समारोह को बदलने के पिछले चरण के परिणाम और लौटने getResponse("a1=चटगांव और ए 2=शहर") जवाब में, आप कर सकते हैं चलाने के लिए इस विधि में एक अलग थ्रेड जब getResponse() तरीकों में प्रतिक्रिया उपलब्ध तो thenApply() लागू किया जा मुद्रित करने के लिए लॉग इन करें. कोई भी अवरुद्ध हो जाएगा, तो आप चलाने के लिए getResponse(स्ट्रिंग यूआरएल) में एक अलग थ्रेड.

इस उदाहरण से पता चलता है, जहां एक परिदृश्य हम मुद्रण कर रहे हैं एक लॉग हो रही है, जबकि प्रतिक्रियाओं से पूर्ण();

कोड

import java.io.IOException;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
import java.util.logging.Level;
import java.util.logging.Logger;

public class CompletableFutureEx {

    Logger logger = Logger.getLogger(CompletableFutureEx.class.getName());

    public static void main(String[] args) {
        new CompletableFutureEx().completableFutureEx();
    }

    private void completableFutureEx() {
        var completableFuture = new CompletableFuture<String>();
        completableFuture.thenApply(response -> {
            logger.log(Level.INFO, "Response : " + response);
            return response;
        });
        
        //some long process response
        try {
            completableFuture.complete(getResponse("a1=Chittagong&a2=city"));
        } catch (Exception e) {
            completableFuture.completeExceptionally(e);
        }

        try {
            System.out.println(completableFuture.get());
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }
    }

    private String getResponse(String url) throws URISyntaxException, IOException, InterruptedException {
        var finalUrl = "http://localhost:8081/api/v1/product/add?" + url;
        //http://localhost:8081/api/v1/product/add?a1=Chittagong&a2=city
        var request = HttpRequest.newBuilder()
                .uri(new URI(finalUrl)).GET().build();
        var response = HttpClient.newHttpClient()
                .send(request, HttpResponse.BodyHandlers.ofString());
        System.out.println("response body " + response.body());
        return response.body();
    }
}