Java Stream subscribeOn 과 publishOn 함수
subscribeOn() 함수 구독(subscription)이 시작되는 스레드를 변경한다. 데이터 소스를 구독하는 스레드를 변경하는 것 publishOn() 함수 다운스트림(downstream) 연산자가 실행되는 스레드를 변경한다. 데이터 소스에서 발행되는 데이터를 처리하는 스레드를 변경 예시 코드 import reactor.core.publisher.Flux; import reactor.core.scheduler.Schedulers; public class Example { public static void main(String[] args) { Flux.just(1, 2, 3) .subscribeOn(Schedulers.elastic()) .map(i -> { // I/O 작업을 수행하는 스레드 변경 return performIOOperation(i); }) .publishOn(Schedulers.parallel()) .map(result -> { // 결과를 처리하는 스레드 변경 return processResult(result); }) .subscribe(); } private static String performIOOperation(int i) { // I/O 작업을 수행 return "result " + i; } private static Stri...