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

안녕하세요? RxJava 학습하시다가 질문 주셨는데요.

아래에 답변 드리도록 하겠습니다.

그런데 해당 강의 마지막 부분에 cold/hot publisher 예제 코드에서 콘솔에 데이터가 출려되는 형태를 보면 구독자1이 데이터를 모두 소비하고 구독자2가 그 다음으로 데이터를 소비하는, 동기적으로 처리하는 것처럼 보이더라구요.

혹시 제 생각처럼 동기적으로 처리되고 있는 것이 맞을까요?

--> 동기적으로 출력되는게 맞습니다. subscribe()에서 콘솔에 출력하는 곳에서 Thread.currentThread().getName() 으로 Thread 이름을 출력해보면 모두다 main 쓰레드에서 실행이 되는 걸 확인하실 수 있을 거에요.

그렇다면 사유가 궁금합니다 ㅠ

--> RxJava나 Reactor 같은 리액티브 프로그래밍 라이브러리는 이벤트 기반의 비동기 프로그래밍 방식의 기술인데요. 비동기 라는 용어는 좁은 의미로는 Java의 동시성 즉, 멀티쓰레딩을 의미하고 넓은 의미로는 동기적으로 순차적으로 실행되지 않는 모든걸로 이해할 수 있습니다.

단순히 Java의 main() 메서드에서 RxJava로 데이터를 통지하고, 데이터를 구독하는것은 main 쓰레드에서만 실행되기 때문에 동기적으로 실행되는 것이구요.

2부에서 스케쥴러를 학습하실텐데요. 스케쥴러를 통해서 비동기적으로 데이터를 통지하거나 데이터를 처리하는 방법에 대해서 학습 하시게 된다는 점 참고해주시면 좋을 것 같습니다.

1. RxJava는 사실 단순 pub/sub 형태의 인터페이스를 구현한 구현체에 불과해서 RxJava를 이용해 소스코드를 작성하여도 이걸 비동기적으로 처리하기 위해서는 더 아랫단의 도움을 받아야 하는건지

   1. 그렇다면 이 코드를 실행하는 was의 영향을 받는건지

   2. 만약 그냥 java로 실행한다면 비동기적으로 실행할 수 없는 건지

2. 아니면 RxJava는 동기적 비동기적으로 소스코드를 작성할 수 있는데, 그냥 현재 예제 코드가 동기적으로 코드를 작성한 것인지

3. 아니면 메인 스레드가 구독자1과 2의 역할을 동시에 하고 있기 때문에 순차처리가 되는것인지
   --> 1, 2, 3번 질문에는 한꺼번에 답변을 드리는게 좋을 것 같아요.

   
   앞에서도 말씀드렸지만 비동기 처리라는 것은 일반적으로 Java에서 멀티 쓰레딩 기법 즉, 쓰레드를 여러개 사용해서 처리하는 것을 의미하는데요. Java에서 비동기 멀티 쓰레딩 이외에 NIO(Non-Blocking I/O)라는 기술이 있습니다. Non-Blocking I/O라는 것은 데이터 입출력 시, 쓰레드가 차단이 되지 않기 때문에 하나의 쓰레드에서 동시 다발적으로 발생하는 입출력을 처리할 수 있는데 이 Non-Blocking I/O 역시도 동기적으로 실행되는 것은 아니기 때문에 비동기적이다라는 표현을 많이 사용합니다.
   Non-Blocking I/O는 일반적으로 Non-Blocking I/O를 지원하는 WAS를 사용하구요. 단순히 Java 만으로 Non-Blocking I/O 기능을 사용하려면 Java의 NIO 기술을 사용하셔야 합니다.

   
   그게 아니라면 멀티쓰레딩 기법을 이용하시면 됩니다.

    

또한 비동기에 대한 정의에 대해 여쭤보고 싶습니다.

비동기 처리라는 것을 스레드의 동작 방식을 제어하는 것이라고 이해하면 될까요??

비동기 처리를 구현하기 위해서는 스레드 제어만 하면 되니까 OS단의 도움을 받지 않고 어플리케이션 단에서 구현을 할 수 있다고 이해해도 괜찮을까요??

--> 위에서 설명 드렸다시피 비동기에 대한 정의는 광범위한 의미까지 포함이 되어 있긴한데 Java에서 일반적으로 비동기 처리라고 하면 멀티 쓰레딩이라고 생각하셔도 무방할 것 같아요.

RxJava 2부에서 스케쥴러를 학습하시면 RxJava에서 멀티 쓰레딩을 손쉽게 적용하실 수 있다는 걸 배우게 되실거에요.

강의에서는 RxJava의 기본 개념이나 연산자의 기본 동작에 대한 이해를 돕기 위해서 무조건적으로 스케쥴러를 사용해서 비동기적으로 처리하지는 않는다고 생각해 주시면 감사드리겠습니다.