1강에 예시로 보여주신 ToDoSample 코드에 관해 질문 드립니다!
356
작성한 질문수 28
안녕하세요! 이제 막 RxJava를 배우기 시작하였습니다 ㅎㅎ
1강 14:20초 즈음에 예시로 보여주신 ToDoSample.class코드에 대해 질문 드립니다.
java app은 main thread가 종료되어도 다른 non-deamon thread가 실행 중이면 app이 종료되지 않는 것으로 알고 있는데,
subscribeOn( Schedulers.io() ) 메소드 실행 시, 다른 thread 가 시작하기도 전에 main thread가 종료되어, 실행 중인 thread가 없어져 app이 종료되었다고 파악해야 할까요??
subscribeOn( Schedulers.io() ) 메소드를 실행하였음에도 왜 다른 스레드가 실행이 바로 되지 않는 걸까요??
답변 1
0
안녕하세요? 낮엔 업무중이고, 밤엔 육아를 해야해서 답변이 조금 늦었습니다. ^^;
질문 주신 내용 중에
java app은 main thread가 종료되어도 다른 non-deamon thread가 실행 중이면 app이 종료되지 않는 것으로 알고 있는데,
에 대한 답변을 드리자면 RxJava의 Scheduler로 생성하는 쓰레드는 디폴트가 daemon thread입니다. 그래서 main thread가 종료되면서 함께 종료가 된다고 보시면 되구요.
만약, subscribeOn(Schedulers.io()) 대신에 subscribeOn(Schedulers.from(Executors.newFixedThreadPool(5)))와 같이 ExecutorServerice를 이용할 경우, 생성되는 thread는 non-daemon thread여서 main thread가 종료되어도 해당 thread는 종료되지 않습니다.
답변이 되셨길 바랍니다.
다른 궁금한 점이 있으시면 언제든지 질문주세요.
감사합니다.
Single과 관련해 여쭤보고 싶은 부분이 있습니다!
0
264
2
cold/hot publisher 예제 코드와 관련해 질문 드립니다.
0
363
1
CompletableObserver 클래스의 람다식 표현관련
0
297
1
데이터 결합 연산자 / merge 관련 질문
0
445
1
DROP 배압 전략에 관한 궁금증
0
300
2
map에서의 TimeUtil.sleep에 관한 궁금점
0
216
1
강의 내용을 정리해서 개인 블로그에 올려도 될까요?
0
562
2
TimeUtil.sleep 관련 질문
0
286
1
배압 전략 중에서 DROP 전략과 관련해서 질문 있습니다.
0
335
1
Error 발생 시에도 계속 처리 방법
0
689
2
선언형 프로그래밍과 명령형 프로그래밍
1
784
2
첫번째 강의 부터 이번강의까지 수강하면서 궁금한점 질문드립니다.
0
325
1
안녕하세요. 질문이 있습니다.
1
354
1
logger 가 없는데 util 폴더도 같이 갖다놔야 하나요?
0
327
1
amb 연산자
0
233
1
질문 드립니다.
0
219
1
concatEager( ) 연산자에 관하여
0
318
1
Reactive Streams의 구성요소들과 RxJava의 구성요소들의 관계?
1
397
2
ObservableSequenceEqualExample.java 예제의 delay( ) 연산자 질문있습니다
0
309
3
defer( ), fromFuture( )도 just( )처럼 여러 인자 값을 받을 수 있는지 궁금합니다.
0
264
3
flatMapSingle() 메소드에 대하여
0
620
6
fromFuture() vs fromCallable() 생성 연산자에 대해
0
573
2
함수형 인터페이스 Comparator에 대해
0
397
2
Publisher와 Subscriber 간의 프로세스 흐름에 대한 질문
1
340
3