[컴] Java Reactor, Threading model

리액터 , rxjava, rxjs

Java Reactor, The threading model

reactor 명령어들은 일반적으로 concurrent agnostic (concurrent 대해서 몰라도 잘 사용할 수 있는)이다. 특정한 thrading model 을 가지고 있진 않다. 단순히 Thread 에서 실행된다. 그 쓰레드에서 그들의 onNext method 가 호출된다.

scheduler 를 통해 user 가 thread 를 통제할 수 있다.

map 연산자는 source thread 에서 실행된다. map 이 수행되기 전에 publishOn 에 넣는 것은 source thread 를 변경하게 된다.

누군가에 의해 만들어진 stream 을 이용하는 경우는 subscribeOn 으로 할 수 있다. source thread 를 변경할 수 있다.

subscribeOn(Schedulers.boundedElastic()) .subscribe(body -> System.out.println() ) 을 사용하면 subscribe call 을 main thread 에서 수행되지만, lamda 는 (System.out.println 이 있는 code block) 새초운 thread 에서 수행된다.

Rederences

1. Flight of the Flux 3 - Hopping Threads and Schedulers