溫馨提示×

springboot多線程返回值怎么獲取

小億
195
2023-11-10 20:31:36
欄目: 編程語言

在Spring Boot中，可以使用CompletableFuture來實(shí)現(xiàn)多線程返回值的獲取。CompletableFuture是Java 8中引入的異步編程工具，用于處理異步操作的結(jié)果。

首先，你需要創(chuàng)建一個CompletableFuture對象，并通過supplyAsync方法指定要執(zhí)行的異步操作。在supplyAsync方法中，你可以使用Lambda表達(dá)式來定義具體的異步任務(wù)。

例如，假設(shè)你想要執(zhí)行一個耗時的操作并返回一個字符串結(jié)果，你可以這樣寫代碼：

import java.util.concurrent.CompletableFuture;

public class MyService {
    
    public CompletableFuture<String> doAsyncOperation() {
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            // 耗時的操作
            String result = "Hello World";
            return result;
        });
        return future;
    }
}

然后，在調(diào)用該方法的地方，你可以使用CompletableFuture的get方法來獲取異步操作的結(jié)果。get方法是一個阻塞方法，會等待異步操作完成并返回結(jié)果。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

@RestController
public class MyController {

    @Autowired
    private MyService myService;

    @GetMapping("/async")
    public String asyncOperation() throws ExecutionException, InterruptedException {
        CompletableFuture<String> future = myService.doAsyncOperation();
        String result = future.get();
        return result;
    }
}

在上面的示例中，asyncOperation方法調(diào)用了doAsyncOperation方法并獲取了一個CompletableFuture對象。然后，通過調(diào)用get方法來獲取異步操作的結(jié)果。

需要注意的是，get方法可能會拋出InterruptedException和ExecutionException異常，需要進(jìn)行相應(yīng)的異常處理。

另外，你還可以使用CompletableFuture提供的其他方法來處理異步操作的結(jié)果，比如thenApply、thenAccept和thenCompose等，具體使用方法可以參考Java的官方文檔。

0 踩