제이슨의 개발이야기

fromFuture() Future 인터페이스 역시 자바 5에서 추가된 동시성 API로 비동기 계산의 결과를 구할 때 사용합니다 보통 Executor 인터페이스를 구현한 클래스에 Callable 객체를 인자로 넣어 Future 객체를 반환합니다 get() 메소드를 호출하면 Callable 객체에서 구현한 계산 결과가 나올 때 까지 블로킹 됩니다 Callable 인터페이스의 call() 메소드는 인자가 없으므로 ()->{} 형태로 나타냈습니다 실행 결과는 1초 쉬고 Hello Future 가 출력됩니다! 참고로 Executors 클래스는 단일 스레드 실행자(SingleThreadExecutor) 뿐만 아니라 다양한 스레드풀(FixedThreadPool, CachedThreadPool) 을 지원합니다 하지만..

just() 나 create() 는 단일 데이터를 다뤘습니다. 그럼 단일 데이터가 아닐 때는 어떻게 해야 할까요? fromXXX() 계열 함수를 사용하면 됩니다 fromArray() fromArray() 함수는 배열에 들어 있는 데이터를 처리할 때 활용하는 함수 입니다 예제 코드! Integer arr[]; arr= new Integer[]{1, 2, 3, 4, 5, 6, 7, 8, 9, 0}; Observable observable = Observable.fromArray(arr); observable.subscribe(System.out::println); fromIterable() Observable 을 만드는 다른 방법은 Iterable 인터페이스를 구현한 클래스에서 Observable 객체를 생..

create() 함수 just() 함수는 데이터를 인자로 넣으면 자동으로 알림 이벤트가 발생하지만 create() 함수는 onNext , onComplete, onError 같은 알림을 개발자가 직접 호출해야 합니다. 그래서 create() 는 라이브러리가 무언가를 해준다기보다 개발자가 무언가를 직접 하는 느낌이 강한 함수 입니다 ex) Observable source = Observable.create( (ObservableEmitter emitter) -> { emitter.onNext(100); emitter.onNext(200); emitter.onNext(300); emitter.onComplete(); }); source.subscribe(System.out::println); 결과 화면 : ..

오늘은 Observable 클래스가 무엇인지 알아보고자 합니다 Rx Java 프로그래밍은 Observable에서 시작해서 Observable 로 끝난다고 해도 과언이 아닐정도로 중요한 개념입니다 그래서 Rx Java 를 공부하기 위해서 Observable에 대해 충분히 숙지 해야 할 필요가 있습니다 Observable 은 옵서버 패턴으로 구현한 클래스로 구현합니다 옵서버 패턴은 객체의 상태 변화를 관찰하는 관찰자(옵서버) 목록을 객체에 등록하고 상태 변화가 있을 때 마다 메서드를 호출하여 객체가 직접 목록의 각 옵서버에게 변화를 알려줍니다 Rx Java 의 Observable은 세 가지의 알림을 구독자에게 전달합니다 꼭 알아두시기 바랍니다! onNext : Observable이 데이터의 발행을 알립니다 ..