인프런 커뮤니티 질문&답변

안녕하세요 강사님

Scheduler의 종류 강의를 수강하고 공부를 하던 와중에 newParallel 메서드에 대해서 궁금증이 생겨서 질문을 하게 됐습니다.

예제 코드에서는 newParallel의 parallelism변수 값을 4를 주셨는데 저는 3을 줘서 테스트를 해봤습니다.

해당 코드로 실행을 하면, 다음과 같은 로그가 나오게 됩니다.

public class SchedulersNewParallelExample01 {
    public static void main(String[] args) {
       Mono<Integer> flux =
          Mono
             .just(1)
             .publishOn(Schedulers.newParallel("Parallel Thread", 3, true));

       //쓰레드 할당
       flux.subscribe(data -> {
          TimeUtils.sleep(5000L);
          Logger.onNext("subscribe 1", data);
       });

       //쓰레드 할당
       flux.subscribe(data -> {
          TimeUtils.sleep(4000L);
          Logger.onNext("subscribe 2", data);
       });

       //쓰레드 할당
       flux.subscribe(data -> {
          TimeUtils.sleep(3000L);
          Logger.onNext("subscribe 3", data);
       });

       //쓰레드 할당
       flux.subscribe(data -> {
          TimeUtils.sleep(2000L);
          Logger.onNext("subscribe 4", data);
       });

       TimeUtils.sleep(8000L);
    }
}

16:18:03.554 [Parallel Thread-3] INFO com.example.springwebflux.util.Logger -- # subscribe 3 onNext(): 1
16:18:04.548 [Parallel Thread-2] INFO com.example.springwebflux.util.Logger -- # subscribe 2 onNext(): 1
16:18:05.560 [Parallel Thread-1] INFO com.example.springwebflux.util.Logger -- # subscribe 1 onNext(): 1
16:18:07.561 [Parallel Thread-1] INFO com.example.springwebflux.util.Logger -- # subscribe 4 onNext(): 1

제가 여기서 여쭤보고 싶은 사항은 다음과 같습니다.

1. Round-Robin 방식을 통해서 각 쓰레드에 작업을 분배하고 더 많은 작업이 들어오면 각 쓰레드의 큐에 작업을 적재하는 것처럼 보이는데요.
   
   작업들을 효율적으로 처리하기 위해서는 먼저 작업이 끝난 Parallel Thread-3에서 남아있는 작업을 가져가서 처리를 하면 좋을 것 같은데 [워크 스틸링(Work Stealing) 같은 처리]
   
   Spring WebFlux에서는 해당 기능은 지원하지 않는 것인지 궁금합니다.

감사합니다