Wpis z mikrobloga

#spring
Mam pytanie jak np. chciałbym CompletableFuture użyć jako wyniku zadania jednego z wielu które chce potem złozyc w strumien (Flux) zadania mam na puli watkow ogolnie tez kazde z nich wywoluje biblioteke w C++ ktora sama poza JVM uzywa n watkow, to czy w Project Reactor nie bedzie to sie jakos klocic z innymi wykonywanami zadaniami?

Zadanie -> zwraca CompletableFuture (wywoluje go watek w JAva a on wola external library poza JVM ktore operuje na n watkach) zadania wszystkie zmieniam na Flux i tam dalej idzie sobie lancuch ale przed wywolaniem tych zadan to tez mam jeszcze dalej ciag strumienia i inne operacje...
Podsumowuac

Mam na pocztku
Mono -> Flux (Flux dostaje od List uruchomionych na ExecutorService) -> Flux
To ze jako jest to reactive stream to tez moge z Project Reactora powolac odpowiedni executor do ich przetwarzania i ciekawe jest zachowanie czy zewn biblioteka dzialajaca poza JVM i zabierajaca przy wykonywaniu sie CompletableFuture n watkow poza JVM to cos sie nie pochrzani? Niestety/stety musze te biblioteke wykorzystywac ze wzgledu na jej performance....