RxJava - Programadores

Los programadores se utilizan en entornos de subprocesos múltiples para trabajar con operadores observables.

Según el Reactive, Scheduler se utilizan para programar cómo se aplicará la cadena de operadores a diferentes subprocesos.

De forma predeterminada, un Observable y la cadena de operadores que le apliques harán su trabajo y notificarán a sus observadores en el mismo hilo en el que se llama a su método Subscribe. El operador SubscribeOn cambia este comportamiento especificando un Programador diferente en el que debería operar el Observable. El operador ObserveOn especifica un Programador diferente que el Observable utilizará para enviar notificaciones a sus observadores.

Hay los siguientes tipos de programadores disponibles en RxJava:

No Señor. Programador y descripción
1

Schedulers.computation()

Crea y devuelve un Programador destinado al trabajo computacional. El recuento de subprocesos que se programarán depende de las CPU presentes en el sistema. Se permite un hilo por CPU. Ideal para bucles de eventos o operaciones de devolución de llamada.

2

Schedulers.io()

Crea y devuelve un planificador destinado al trabajo vinculado a IO. El grupo de subprocesos puede extenderse según sea necesario.

3

Schedulers.newThread()

Crea y devuelve un planificador que crea un nuevo subproceso para cada unidad de trabajo.

4

Schedulers.trampoline()

Crea y devuelve un Programador que pone en cola el trabajo en el hilo actual para que se ejecute después de que se complete el trabajo actual.

4

Schedulers.from(java.util.concurrent.Executor executor)

Convierte un Ejecutor en una nueva instancia de Programador.