Tenga en cuenta que debemos asegurarnos de que el hilo principal que ejecuta el programa no terminar (ya que todos los Observables ahora se están ejecutando en sus propios hilos) esperando para la entrada del usuario. La salida de esta versión es: Lambda2 Recibido 2 Lambda1 Recibido 2 Lambda2 Recibido 3 Lambda2 Recibido 5 Lambda1 Recibido 3 Lambda1 Recibido 5 Presiona enter para terminar Lambda3 Recibido 2 Lambda3 Recibido 3 Lambda3 Recibido 5 De forma predeterminada, la palabra clave del programador en el método subscribe() tiene como valor predeterminado Ninguno que indica que el subproceso actual se utilizará para la suscripción al Observable. 36.6.1 Programadores disponibles Para admitir diferentes estrategias de programación, la biblioteca RxPy proporciona dos módulos que suministran diferentes planificadores; la concurrencia rx.y rx. moneda.mainloopscheduler. Los módulos contienen una variedad de programas ulers, incluidos los que se enumeran a continuación. Los siguientes programadores están disponibles en el módulo rx.concurrency: • ImmediateScheduler Esto programa una acción para su ejecución inmediata. • CurrentThreadScheduler Esto programa la actividad para el subproceso actual. • TimeoutScheduler Este programador funciona a través de una devolución de llamada cronometrada. • NewThreadScheduler crea un programador para cada unidad de trabajo en un hilo de arata. • ThreadPoolScheduler. Este es un planificador que utiliza un grupo de subprocesos para ejecutar trabajo. Este programador puede actuar como una forma de limitar la cantidad de trabajo llevado a cabo concurrentemente. El módulo rx.concurrency.mainloopschduler también define los siguientes bajando programadores: • IOLoopScheduler Un programador que programa el trabajo a través de Tornado I/O bucle de evento principal. • PyGameScheduler Un programador que programa trabajos para PyGame. • WxScheduler Un programador para un bucle de eventos de wxPython. 36.6 Concurrencia de observadores 437