조금 더 자세한 설명부탁드립니다

Question

해당 강의에서 추가 설명에 대해 이해가 되지 않아서 조금 더 자세한 설명 부탁드립니다. 우선, 제가 임의로 아래 코드처럼 main 스레드를 0.5초 동안 일시 정지 를 적용 시켜보았더니 정상적으로 동작했습니다. - UnitTestNotByRxJava.java (Test) public class UnitTestNotByRxJava { @Test public void getCarMakerStreamSyncTest (){ List < CarMaker > carMakerList = new ArrayList <>() ; SampleObservable. getCarMakerStream () .subscribe ( data -> carMakerList .add ( data )) ; TimeUtil. sleep ( 500L ) ; assertThat ( carMakerList.size () , is ( 5 )) ; } } - SampleObservable.java public class SampleObservable { ... public static Observable < CarMaker > getCarMakerStream () { Observable < CarMaker > observable = Observable. fromArray ( SampleData. carMakers) .subscribeOn ( Schedulers. computation ()) ; return observable ; } ... } 즉, 기존 예제에서 오류가 나는 이유가, main 스레드와 호출 함수 getCarMakerStream 내 'RxComputationThreadPool' 스레드가 동시에 실행이 되어 그 짧은 시간 사이에 main 스레드에서 결과 값을 리턴받지 못하기 때문이다라고 이해하면 될까요?

Kevin · Answer

안녕하세요? 질문 주신 부분에 대해서 답변을 드리겠습니다. " 즉, 기존 예제에서 오류가 나는 이유가, main 스레드와 호출 함수 getCarMakerStream 내 'RxComputationThreadPool' 스레드가 동시에 실행이 되어  그 짧은 시간 사이에 main 스레드에서 결과 값을 리턴받지 못하기 때문이다라고 이해하면 될까요?"  말씀하신 내용과 거의 비슷한데요. main 쓰레드와 RxComputationThreadPool 쓰레드가 동시에 실행되는 것이 아니라  RxComputationThreadPool 쓰레드에서 실행되는 RxJava 코드보다 main 쓰레드에서 실행되는 assertThat 코드가 먼저 실행이 되기때문에 테스트에 실패하는것입니다. 그래서 질문자님이 0.5초 딜레이를 준 그 시점에는 아래쪽 assertThat 코드가 실행이 되지 않고, 윗쪽의 RxJava 코드가 먼저 실행이 되는 것입니다. 답변이 충분한지 모르겠네요. ^^;

easyvvon · Answer

답변 감사합니다! 제가 test가 아닌 환경에서 해당 예제를 가지고 assertThat( ) 메소드를 제외하고 실행시켜 보아도 subscribe( ) 메소드에 결과가 나오지 않더라구요 이것도 RxComputationThreadPool로부터의 데이터를 통지도 하기 전에 main 스레드에서의 작업이 끝나서 결과 값이 안나온 것이군요? List < CarMaker > carMakerList = new ArrayList <>() ; SampleObservable. getCarMakerStream () .map ( data -> carMakerList .add ( data )) .subscribe ( data -> Logger. log ( LogType. ON_NEXT , carMakerList )) ; // TimeUtil.sleep(1000L); - 스레드 지연 시간 적용 시 결과 onNext() | RxComputationThreadPool-1 | 22:51:26.875 | [CHEVROLET] onNext() | RxComputationThreadPool-1 | 22:51:26.877 | [CHEVROLET, HYUNDAE] onNext() | RxComputationThreadPool-1 | 22:51:26.877 | [CHEVROLET, HYUNDAE, SAMSUNG] onNext() | RxComputationThreadPool-1 | 22:51:26.878 | [CHEVROLET, HYUNDAE, SAMSUNG, SSANGYOUNG] onNext() | RxComputationThreadPool-1 | 22:51:26.878 | [CHEVROLET, HYUNDAE, SAMSUNG, SSANGYOUNG, KIA]