我正在使用 Spring WebFlux,我需要執行非同步任務作為方法的一部分,該方法不應阻止對使用者的主要回應。具體來說,我想在完成主要任務後呼叫非同步方法,但不延遲回應。
這是我想要實現的目標的簡化版本:
public MonopublishPackage(RequestDTO requestDTO) { return publishPackageService.doSomething(requestDTO) .flatMap(responseDTO -> doSomethingInAsync(requestDTO, responseDTO) .thenReturn(responseDTO) ); } // Method that simulates an asynchronous task with a 5-second delay public Mono doSomethingInAsync(RequestDTO requestDTO, ResponseDTO responseDTO) { return Mono.delay(Duration.ofSeconds(5)) .then(); // Converts the delayed Mono to Mono }
此呼叫完成後,我想非同步執行 doSomethingInAsync(requestDTO, responseDTO)。
doSomethingInAsync 方法應該是非阻塞的,並且不會延遲主要反應。
問題:
doSomethingInAsync 方法正在執行,但它似乎可能會阻止回應或未按預期非同步運作。如何確保 doSomethingInAsync 非同步運作並且不會阻止對使用者的回應?
細節:
publishPackageService.doSomething(requestDTO): 回傳一個 Mono。
doSomethingInAsync(requestDTO, responseDTO):是一個非同步方法,我想在不阻塞回應的情況下運行它。
問題:
如何確保 doSomethingInAsync 在背景運作而不阻塞回應?
免責聲明: 提供的所有資源部分來自互聯網,如果有侵犯您的版權或其他權益,請說明詳細緣由並提供版權或權益證明然後發到郵箱:[email protected] 我們會在第一時間內為您處理。
Copyright© 2022 湘ICP备2022001581号-3