-
SubscribeOn 와 ObserveOn 그리고 SchedulersAndroid/Rx 2019. 10. 7. 00:03반응형
SubscribeOn
SubscribeOn은 구독(subscribe)에서 사용할 스레드를 지정
도중 ObserveOn이 호출되어도 SubscribeOn의 스레드 지정에는 영향을 끼치지 않는다.
ObserveOn
ObserveOn은 Observable이 다음처리를 진행할때 사용할 스레드를 지정
ObserveOn이 선언된 후 처리가 진행뒤 다른 ObserveOn이 선언시 다른 ObserveOn에서 선언한 스레드로 변경되어 이후 처리를 진행한다.
Schedulers
Observable 연산자 체인에 멀티스레딩을 적용하고 싶다면, 특정 스케줄러를 사용해서 연산자(또는 특정 Observable)를 실행하면 된다.
ReactiveX의 일부 Observable 연산자는 사용할 스케줄러를 파라미터로 전달 받기도 하는데, 이 연산자들은 자신이 처리할 연산의 일부 또는 전체를 전달된 스케줄러 내에서 실행한다.
기본적으로, Observable과 연산자 체인은 이처럼 스케줄러를 통해 동작하고 Subscribe 메서드가 호출되는 스레드를 사용해서 옵저버에게 알림을 보낸다. SubscribeOn 연산자는 다른 스케줄러를 지정해서 Observable이 처리해야 할 연산자들을 실행 시킨다. 그리고, ObserveOn 연산자는 Observable이 옵저버에게 알림을 보낼때 사용 할 스케줄러를 명시한다.아래 그림이 보여주듯, SubscribeOn 연산자는 Observable이 연산을 위해 사용할 스레드를 지정하며, 연산자 체인 중 아무 곳에서 호출해도 문제되지 않는다. 하지만, ObserveOn 연산자는 연산자 체인 중 Observable이 사용할 스레드가 호출 체인 중 어느 시점에서 할당되는지에 따라 그 후에 호출되는 연산자는 영향을 받는다. 그렇기 때문에, 어쩌면 여러분은 특정 연산자를 별도의 스레드에서 실행 시키기 위해 연산자 체인 중 한 군데 이상에서ObserveOn을 호출하게 될 것이다.
http://reactivex.io/documentation/scheduler.html Schedulers.computation() - 이벤트 룹에서 간단한 연산이나 콜백 처리를 위해서 쓰는 것입니다. I/O 처리를 여기에서 해서는 안됩니다.
Schedulers.from(executor) - 특정 executor를 스케쥴러로 사용합니다.
Schedulers.immediate() - 현재 스레드에서 즉시 수행합니다.
Schedulers.io() - 동기 I/O를 별도로 처리시켜 비동기 효율을 얻기 위한 스케줄러입니다. 자체적인 스레드 풀에 의존합니다.
Schedulers.newThread() - 항상 새로운 스레드를 만드는 스케쥴러입니다.
Schedulers.trampoline() - 큐에 있는 일이 끝나면 이어서 현재 스레드에서 수행하는 스케쥴러.AndroidSchedulers.mainThread() - 안드로이드의 UI 스레드에서 동작합니다.
HandlerScheduler.from(handler) - 특정 핸들러 handler에 의존하여 동작합니다.[참고링크]
http://reactivex.io/documentation/operators/subscribeon.html
ReactiveX - SubscribeOn operator
To specify on which Scheduler the Observable should operate, use the subscribeOn operator, passing it the appropriate Scheduler. To specify which Scheduler observers will use to unsubscribe from an Observable, use the unsubscribeOn operator, passing it the
reactivex.io
http://reactivex.io/documentation/operators/observeon.html
ReactiveX - ObserveOn operator
To specify on which Scheduler the Observable should invoke its observers’ onNext, onCompleted, and onError methods, use the observeOn operator, passing it the appropriate Scheduler. Sample Code /* Change from immediate scheduler to timeout */ var source =
reactivex.io
http://reactivex.io/documentation/scheduler.html
ReactiveX - Scheduler
In RxJS you obtain Schedulers from the Rx.Scheduler object or as independently-implemented objects. The following table shows the varieties of Scheduler that are available to you in RxJS:. Schedulerpurpose Rx.Scheduler.currentThreadschedules work as soon a
reactivex.io
https://bsscco.github.io/2019/04/07/rx-subscribe-on-and-observe-on/
RxJava SubscribeOn과 ObserveOn의 동작 차이
참고 : https://github.com/ReactiveX/RxAndroid/blob/2.x/README.md SubscribeOnObservable의 create()부터 onNext(), onComplete(), onError()까지 모든 과정을 subscribeOn()으로 지정한 스레드에서 실행시킨다. ObserveOnObservable의 메소드체인
bsscco.github.io
https://yunhookim.tistory.com/10
Rxjava subscribeOn과 observeOn 차이
안드로이드 리액티브 프로그래밍을 하면서 subscribeOn()과 observeOn()의 차이를 명확하게 모르겠어서 여러 자료를 찾아보다 쉽게 블로깅합니다. subscribeOn() - subscribeOn은 Observable 객체가 실행될 쓰레드..
yunhookim.tistory.com
https://medium.com/upday-devs/rxjava-subscribeon-vs-observeon-9af518ded53a
RxJava: subscribeOn vs observeOn
One of the strongest aspects of RxJava is the simple way to schedule work on a desired thread using either subscribeOn or observeOn. While…
medium.com
http://minsone.github.io/programming/reactive-swift-observeon-subscribeon
[ReactiveX][RxSwift]Scheduler, observeOn, subscribeOn
Rx를 다루다보면 멀티스레드가 필요한 작업이 많아 observeOn과 subscribeOn을 같이 쓸 일이 많은데, 이를 정리하고자 합니다. Scheduler 멀티스레드를 사용하여 여러가지 작업을 Observable 연산자로 묶어 수행하는 경우가 있습니다. 가령 백그라운드 스레드에서는 네트워크 작업, 많은 연산이 필요한 작업을 해야하고, 화면에 보여주기 위해서는 메인 스레드에서 작업을 해야합니다. 이 작업들은 Observable 연산자로 묶어 만들 수 있
minsone.github.io
http://blog.weirdx.io/post/26576
[ReactiveX][RxSwift]observeOn, subscribeOn - 작업 스레드 지정하기 - 이상한모임
Rx를 다루다보면 observeOn과 subscribeOn을 같이 쓸 일이 많은데, 이를 정리하고자 합니다.
blog.weirdx.io
https://altongmon.tistory.com/763
[RxJava2] 스케줄러 종류와 사용 법 : newThread(), computation(), io(), trampoline(), single(), from(executor)
공감 및 댓글은 포스팅 하는데 아주아주 큰 힘이 됩니다!! 포스팅 내용이 찾아주신 분들께 도움이 되길 바라며 더 깔끔하고 좋은 포스팅을 만들어 나가겠습니다^^ 이번 포스팅에서는 스케줄러의 종류와 사용법에..
altongmon.tistory.com
2. 스케쥴러 이해하기
2016/02/17 - [Rxandroid] - 0. RxAndroid의 시작 2016/02/18 - [Rxandroid] - 1. RxAndroid를 적용해보고 HelloWorld를 찍어보자. 2016/02/19 - [Rxandroid] - 1-1. RxAndroid MVP Sample RxAndroid에서는 스케..
tiii.tistory.com
반응형'Android > Rx' 카테고리의 다른 글
RxJava2로 EventBus 구현 하기 (Rxbus) (0) 2020.03.20 ReactiveX - Subject (0) 2019.09.04