Programación Reactiva con RxJava

Capítulo 5. Reactivo de arriba abajo

Este trabajo se ha traducido utilizando IA. Agradecemos tus opiniones y comentarios: [e-mail]

Tomasz Nurkiewicz

"Todo es un flujo" es un zen de RxJava que se cita a menudo. En el Capítulo 4, aprendimos a implementar RxJava en algunos lugares de nuestra base de código.Pero lo que descubrirás rápidamente es que las aplicaciones verdaderamente reactivas utilizan flujos prácticamente de arriba abajo. Este enfoque simplifica el razonamiento y hace que nuestra aplicación sea muy coherente. Las aplicaciones no bloqueantes tienden a proporcionar un gran rendimiento y producción por una fracción del hardware. Al limitar el número de hilos, podemos utilizar plenamente la CPU sin consumir gigabytes de memoria.

Uno de los factores limitantes de la escalabilidad en Java es el mecanismo de E/S. El paquete java.io está muy bien diseñado, con montones de pequeñas implementaciones de Input/OutputStream y Reader/Writer que se decoran y envuelven unas a otras, añadiendo una funcionalidad cada vez. Por mucho que me guste esta hermosa separación de preocupaciones, la E/S estándar en Java es totalmente bloqueante, lo que significa que cada subproceso que desee leer o escribir desde un Socket o File debe esperar indefinidamente el resultado. Peor aún, los subprocesos atascados en una operación de E/S debido a una red lenta o a un disco que gira aún más lento son difíciles de interrumpir. El bloqueo en sí mismo no es un problema, cuando un hilo ...