[목차]==================================================
1. RxJava와 RxAndroid에서 제공하는 Scheduler 종류
1) RxJava가 제공하는 Scheduler
2) RxAndroid는 제공하는 Scheduler
2. 독립적으로 사용 가능한 Scheduler
3. 사용법 예제
1) Scheduler 안한 경우 기본 동작
2) subscribeOn() API만 사용한 경우 동작
3) observerOn() API만 사용한 경우 동작
4) subscribeOn() & observerOn() 1번씩 API 사용한 경우 동작
5) subscribeOn() & observerOn() 다수 API 사용한 경우 동작
======================================================
RxAndroid에서는 Scheduler를 통해 어느 쓰레드에서 실행이 될지 결정 할 수 있습니다.
Scheduler는 subsctibeOn(), observeOn() 에서 각각 지정할 수 있는데
subsctibeOn()은 observable의 작업을 시작하는 쓰레드를 선택 할 수 있습니다.( 중복해서 적을 경우 가장 마지막에 적힌 스레드에서 시작합니다.)
observeOn()은 이후에 나오는 Operator, subscribe의 Scheduler를 변경 할 수 있습니다.
1. RxJava와 RxAndroid에서 제공하는 Scheduler 종류
1) RxJava가 제공하는 Scheduler
이벤트 룹에서 간단한 연산이나 콜백 처리를 위해서 쓰는 것입니다. I/O 처리를 여기에서 해서는 안됩니다.
RxComputationThreadPool라는 별도의 스레드 풀에서 돌아갑니다. 최대 cpu갯수 ?개의 스레드 풀이 순환하면서 실행됩니다.
- Schedulers.from(executor)
특정 executor를 스케쥴러로 사용합니다
현재 스레드에서 즉시 수행합니다.
observeOn()이 여러번 쓰였을 경우 immediate()를 선언한 바로 윗쪽의 스레드를 따라갑니다.
동기 I/O를 별도로 처리시켜 비동기 효율을 얻기 위한 스케줄러입니다. 자체적인 스레드 풀에 의존합니다.
자체적인 스레드 풀 CachedThreadPool을 사용합니다. API 호출 등 네트워크를 사용한 호출 시 사용됩니다.
항상 새로운 스레드를 만드는 스케쥴러입니다.
큐에 있는 일이 끝나면 이어서 현재 스레드에서 수행하는 스케쥴러
※ 일부 오퍼레이터들은 자체적으로 어떤 스케쥴러를 사용할지 지정합니다. 예를 들어 buffer 오퍼레이터는 Schedulers.computation()에 의존하며 repeat은 Schedulers.trampoline()를 사용합니다.
2) RxAndroid는 제공하는 Scheduler
- AndroidSchedulers.mainThread()
안드로이드의 UI 스레드에서 동작
- HandlerScheduler.from(handler)
특정 핸들러 handler에 의존하여 동작
※ 안드로이드에 특화된 스케쥴러입니다. 보통은 RxAndroid가 제공하는 AndroidSchedulers.mainThread()와 RxJava가 제공하는 Schedulers.io()를 조합해서 Schedulers.io()에서 수행한 결과를 AndroidSchedulers.mainThread()에서 받아 UI에 반영하는 패턴등이 일반적으로 쓰입니다.
2. 독립적으로 사용 가능한 Scheduler
Scheduler는 Observable, Operator, Subscriber 모델 밖에서 별도로 사용할 수 있습니다.
|
worker = Schedulers.newThread().createWorker();
worker.schedule(new Action0() {
@Override
public void call() {
realmJob();
}
}); |
|
Scheduler.Worker worker = Schedulers.newThread().createWorker();
worker.schedule(new Runnable() {
@Override
public void run() {
log("worker: " + Thread.currentThread().getName());
}
}); |
|
[출력결과]
worker: RxNewThreadScheduler-1 |
3. 사용법 예제
1) Scheduler 안한 경우 기본 동작
|
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> e) throws Exception {
log("subscribe:" + Thread.currentThread().getName());
e.onNext("next");
}
}).map(s1 -> {
log("map: " + Thread.currentThread().getName());
return s1;
}).subscribe(s -> log("on next: " + Thread.currentThread().getName())); |
|
[출력결과]
subscribe:main
map: main
on next: main |
2) subscribeOn() API만 사용한 경우 동작
|
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> e) throws Exception {
log("subscribe:" + Thread.currentThread().getName());
e.onNext("next");
}
}).subscribeOn(Schedulers.computation()).map(s1 -> {
log("map: " + Thread.currentThread().getName());
return s1;
}).subscribe(s -> log("on next: " + Thread.currentThread().getName())); |
|
[출력결과]
subscribe:RxComputationThreadPool-1
map: RxComputationThreadPool-1
on next: RxComputationThreadPool-1 |
3) observerOn() API만 사용한 경우 동작
|
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> e) throws Exception {
log("subscribe:" + Thread.currentThread().getName());
e.onNext("next");
}
}).observeOn(Schedulers.computation()).map(s1 -> {
log("map: " + Thread.currentThread().getName());
return s1;
}).subscribe(s -> log("on next: " + Thread.currentThread().getName())); |
|
[출력결과]
subscribe:main
map: RxComputationThreadPool-1
on next: RxComputationThreadPool-1 |
4) subscribeOn() & observerOn() 1번씩 API 사용한 경우 동작
|
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> e) throws Exception {
log("subscribe:" + Thread.currentThread().getName());
e.onNext("next");
}
}).subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.map(s1 -> {
log("map: " + Thread.currentThread().getName());
return s1;
}).subscribe(s -> log("on next: " + Thread.currentThread().getName())); |
|
[출력결과]
subscribe:RxCachedThreadScheduler-1
map: main
on next: main |
5) subscribeOn() & observerOn() 다수 API 사용한 경우 동작
|
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> e) throws Exception {
log("subscribe:" + Thread.currentThread().getName());
e.onNext("next");
}
}).subscribeOn(Schedulers.io())
.subscribeOn(Schedulers.computation())
.observeOn(AndroidSchedulers.mainThread()).map(s1 -> {
log("map1: " + Thread.currentThread().getName());
return s1;
}).observeOn(Schedulers.newThread()).map(s2 -> {
log("map2: " + Thread.currentThread().getName());
return s2;
}).observeOn(Schedulers.single()).map(s3 -> {
log("map3: " + Thread.currentThread().getName());
return s3;
}).subscribe(s -> log("on next: " + Thread.currentThread().getName())); |
|
[출력결과]
subscribe:RxCachedThreadScheduler-1
map1: main
map2: RxNewThreadScheduler-1
map3: RxSingleScheduler-1
on next: RxSingleScheduler-1 |
출처 : 인터넷에서 RxAndroid 검색하여 필요한 정보를 다양한 사이트에서 종합하여 작성된 것입니다. 많은 사이트 내용을 종합하여 공부하여 작성하다보니 일일이 나열하지 못하였습니다. ㅈㅅ(_ _) 이글은 자유롭게 퍼 가셔서 도움이 되었으면 좋겠습니다. 감사합니다.
