observeOn 2 ObserveOn(), SubscribeOn(), PublishOn() Reactive Programming에서 작업 스레드 관리는 보통 두가지 연산자를 사용하여 처리됩니다. 아래는 그 두 예시입니다. 또 대표적으로 사용되는 ReactiveX와 Reactor의 관점에서 보겠습니다. subscribeOn() ReactiveX의 관점에서의 SubscribeOn은 데이터를 생성하고, I/O 작업을 수행하는 스레드를 지정합니다. 즉, Observable을 실행할 스레드를 결정하는 메함수로 Observable이 Subscribe 되었을 때, 어떤 Thread에서 실행할지를 결정하는 역할을 합니다. 이를 통해, CPU 작업과 I/O 작업이 동시에 일어나는 비동기 처리를 가능케 합니다. 이때, 지정되는 Thread는 ReactiveX의 Schedulers에서 선택할 수 있습니다. Rea.. Domain/Reactive Programming 2023. 5. 12. [ReactiveX] SubscribeOn vs ObserveOn RxJava 스케줄러의 핵심은 결국 제공되는 스케줄러의 종류를 선택한 후 subscribeOn()과 observeOn() 함수를 호출하는 것이라고 할 수 있습니다. subscribeOn() Observable에서 구독자가 subscribe() 함수를 호출했을 때 데이터 흐름을 발행하는 스레드를 지정하는 역할을 합니다. subscribeOn() 함수는 처음 지정한 스레드를 고정시키므로 다시 subscribeOn() 함수를 호출해도 무시합니다. observeOn() 처리된 결과를 구독자에게 전달하는 스레드를 지정하는 역할을 합니다. observeOn()은 여러 번 호출할 수 있으며 호출되면 그다음부터 동작하는 스레드를 바꿀 수 있다. observeOn()함수를 지정하지 않으면 subscribeOn() 함수로.. Domain/ReactiveX 2021. 4. 29. 이전 1 다음
