RxJava - Zamanlayıcılar
Zamanlayıcılar, Gözlemlenebilir operatörlerle çalışmak için çoklu iş parçacığı ortamında kullanılır.
Göre Reactive, Zamanlayıcı, işleçler zincirinin farklı iş parçacıklarına nasıl uygulanacağını planlamak için kullanılır.
Varsayılan olarak, bir Gözlemlenebilir ve ona uyguladığınız işleçler zinciri işini yapacak ve gözlemcilerini Abone olma yönteminin çağrıldığı aynı iş parçacığı üzerinden bilgilendirecektir. Abone Olma işleci, Gözlemlenebilir öğenin üzerinde çalışması gereken farklı bir Zamanlayıcı belirleyerek bu davranışı değiştirir. ObserveOn operatörü, Gözlemlenebilir'in gözlemcilerine bildirimler göndermek için kullanacağı farklı bir Zamanlayıcı belirtir.
RxJava'da aşağıdaki Zamanlayıcı türleri mevcuttur -
| Sr.No. | Zamanlayıcı ve Açıklama |
|---|---|
| 1 | Schedulers.computation() Hesaplama çalışması için tasarlanmış bir Zamanlayıcı oluşturur ve döndürür. Programlanacak iş parçacığı sayısı, sistemde bulunan CPU'lara bağlıdır. CPU başına bir iş parçacığına izin verilir. Olay döngüleri veya geri arama işlemleri için idealdir. |
| 2 | Schedulers.io() GÇ'ye bağlı çalışmaya yönelik bir Zamanlayıcı oluşturur ve döndürür. İş parçacığı havuzu gerektiği kadar genişletilebilir. |
| 3 | Schedulers.newThread() Her çalışma birimi için yeni bir İş Parçacığı oluşturan bir Zamanlayıcı oluşturur ve döndürür. |
| 4 | Schedulers.trampoline() Geçerli iş tamamlandıktan sonra yürütülecek mevcut iş parçacığı üzerinde kuyrukların çalıştığı bir Zamanlayıcı oluşturur ve döndürür. |
| 4 | Schedulers.from(java.util.concurrent.Executor executor) Bir Yürütücüyü yeni bir Zamanlayıcı örneğine dönüştürür. |