Jaké mechanismy se v RxJava používají k řízení přepínání vláken?

V RxJava se používají operátory subscribeOn() a observeOn() k řízení vláken provádění.

• subscribeOn() určuje, na jakém vlákně bude probíhat předplatné a vykonávání původního Observable. Obvykle se používá k označení pozadí vlákna, například Schedulers.io() pro vstupně-výstupní operace.

• observeOn() přepíná vlákno, na kterém budou zpracovávány následující operátory a koneční odběratelé. Například lze přepnout na hlavní vlákno Androidu pomocí AndroidSchedulers.mainThread().

Příklad:

Observable.just("data")
    .subscribeOn(Schedulers.io())          // provádění na pozadí vlákno
    .observeOn(AndroidSchedulers.mainThread()) // zpracování výsledku na UI vlákně
    .subscribe(data -> {
        // aktualizace UI
    });

Tímto způsobem subscribeOn nastaví vlákno zdroje dat, a observeOn vlákno pro zpracování výsledků.