Scheduler

TBD

TBD

Jenis-jenis Scheduler

Anda mendapatkan sebuah Scheduler dari sebuah factory method yang dijelaskan di class Schedulers. Table berikut menunjukkan berbagai jenis Scheduler yang bisa anda pakai di RxGroovy:

Scheduler default untuk Operator Observable RxGroovy

Beberapa operator Observable di RxGroovy memiliki beberapa bentuk lain yang memungkinkan anda untuk mengatur Scheduler tempat operator tersebut akan bekerja. Yang lainnya tidak akan beroperasi pada Scheduler tertentu, atau beroperasi pada Scheduler default tertentu. Untuk yang memiliki Scheduler default tertentu termasuk:

Test Scheduler

TestScheduler memungkinkan anda untuk melakukan kontrol manual yang dapat disesuaikan dengan bagaimana waktu Scheduler bekerja. Ini dapat berguna untuk menguji interaksi yang bergantung pada penyusunan aksi sesuai waktunya. Scheduler ini mempunyai tiga method tambahan:

advanceTimeTo(time,unit)

memajukan waktu scheduler ke suatu titik waktu tertentu

advanceTimeBy(time,unit)

memajukan waktu scheduler ke depan dengan suatu unit waktu tertentu

triggerActions( )

memulai aksi yang belum dimulai yang sudah dijadwalkan pada suatu waktu pada saat sekarang ataupun di masa lalu sesuai waktu Scheduler

Lihat Juga

• Testing Reactive Applications oleh Ben Christensen
• RxJava Threading Examples oleh Graham Lea
• Advanced RxJava: Schedulers (part 1) (part 2) (part 3) (part 4) oleh Dávid Karnok

Jenis-jenis Scheduler

Anda mendapatkan sebuah Scheduler dari factory method yang dideskripsikan di class Schedulers. Table berikut menunjukkan jenis Scheduler yang dapat dipakai di RxJava::

Scheduler Default untuk Operator Observable RxJava 1.x

Beberapa operator Observable di RxJava memiliki bentuk lain yang memungkinkan anda untuk mengatur Scheduler yang akan dipakai operator untuk (setidaknya beberapa bagian) dari operasinya. Yang lainnya tidak beroperasi pada Scheduler tertentu, atau beroperasi pada Scheduler default tertentu. Operator yang memiliki Scheduler default tertentu termasuk:

Memakai Scheduler

Selain dari meneruskan Scheduler tersebut kedalam operator Observable RxJava, anda juga bisa menggunakan mereka untuk menjadwalkan pekerjaan anda pada Subscription. Contoh berikut menggunakan method schedule dari class Scheduler.Worker untuk menjadwalka pekerjaan pada scheduler newThread:

worker = Schedulers.newThread().createWorker();
worker.schedule(new Action0() {

    @Override
    public void call() {
        yourWork();
    }

});
// some time later...
worker.unsubscribe();

Scheduler Rekursif

Untuk menjadwalkan pemanggilan schedule rekursif, anda bisa menggunakan schedule dan kemudian schedule(this) pada object Worker:

worker = Schedulers.newThread().createWorker();
worker.schedule(new Action0() {

    @Override
    public void call() {
        yourWork();
        // recurse until unsubscribed (schedule will do nothing if unsubscribed)
        worker.schedule(this);
    }

});
// some time later...
worker.unsubscribe();

Mengecek atau Menyetel Status Unsubscribed

Obyek-obyek dari class Worker class mengimplementasi inteface Subscription, dengan method isUnsubscribed dan unsubscribe, sehingga anda bisa berhenti bekerja ketika sebuah subscription dibatalkan, atau anda juga bisa membatalkan subscription tersebut dari dalam task yang sudah dijadwalkan:

Worker worker = Schedulers.newThread().createWorker();
Subscription mySubscription = worker.schedule(new Action0() {

    @Override
    public void call() {
        while(!worker.isUnsubscribed()) {
            status = yourWork();
            if(QUIT == status) { worker.unsubscribe(); }
        }
    }

});

Worker juga merupakan sebuah Subscription sehingga anda juga bisa (dan harus, pada akhirnya) memanggil method unsubscribe nya untuk memberitahukan bahwa itu bisa menghentikan pekerjaannya dan melepaskan sumber dayanya:

worker.unsubscribe();

Scheduler Delayed dan Periodic

Anda juga bisa menggunakan sebuah versi dari schedule yang menunda aksi dari Scheduler sampai melewati jangka waktu tertentu. Contoh berikut menjadwalkan someAction untuk dijalankan pada someScheduler setelah 500ms telah berlalu pada waktu Scheduler tersebut:

someScheduler.schedule(someAction, 500, TimeUnit.MILLISECONDS);

Method Another Scheduler memungkinkan anda untuk menjadwalkan sebuah aksi untuk berjalan pada sebuah interval yang teratur. Contoh berikut menjadwalkan someAction untuk dikerjakan pada someScheduler setelah 500ms telah berlalu, dan kemudian setiap 250ms setelahnya:

someScheduler.schedulePeriodically(someAction, 500, 250, TimeUnit.MILLISECONDS);

Test Scheduler

TestScheduler memungkinkan anda untuk melakukan kontrol manual yang dapat disesuaikan dengan bagaimana waktu Scheduler bekerja. Ini dapat berguna untuk menguji interaksi yang bergantung pada penyusunan aksi sesuai waktunya. Scheduler ini mempunyai tiga method tambahan:

advanceTimeTo(time,unit)

memajukan waktu scheduler ke suatu titik waktu tertentu

advanceTimeBy(time,unit)

advances the Scheduler’s clock forward by a particular amount of time

triggerActions( )

memulai aksi yang belum dimulai yang sudah dijadwalkan pada suatu waktu pada saat sekarang ataupun di masa lalu sesuai waktu Scheduler

Lihat Juga

• RxJava Threading Examples oleh Graham Lea
• Testing Reactive Applications oleh Ben Christensen
• Advanced RxJava: Schedulers (part 1) (part 2) (part 3) (part 4) oleh Dávid Karnok