newScheduledThreadPool Metodi

Yana bir turdagi thread pool— rejalashtirilgan vazifalar puli. Nomidan kelib chiqib, biz bu turdan vaqt bo'yicha taqsimlangan vazifalarni amalga oshirishni rejalashtirish uchun foydalanishimiz mumkinligini taxmin qilish mumkin.

Bu xizmat turi, ma'lum bir vaqt o'tganidan keyin yoki vazifaning muntazam bajarilishi bilan bog'liq vazifalarni bajarish kerak bo'lganda foydalidir.

Foydalanish uchun Executors.newScheduledThreadPool(1) ni chaqiramiz.

Parametrlari haqida keyinroq gaplashamiz, hozir biz ushbu metodni chaqirishda bizga ScheduledExecutorService turidagi ob'ekt qaytarilishi muhimligini tushunishimiz kerak.

ScheduledExecutorService — bu ExecutorServicedan meros olingan interfeys.

Ushbu interfeysda quyidagi metodlar mavjud:

ScheduledFuture<?>
schedule(Runnable command,
                                  long delay, TimeUnit unit);

<V> ScheduledFuture<V>
schedule(Callable<V> callable,
                                      long delay, TimeUnit unit);

ScheduledFuture<?>
scheduleAtFixedRate(Runnable command,
                                             long initialDelay,
                                             long period,
                                             TimeUnit unit);

ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                long initialDelay,
                                                long delay,
                                                TimeUnit unit);

Ko'rib turganimizdek, interfeys bizga vazifalarni ma'lum bir davrda yoki ma'lum bir vaqt o'tib ishga tushirish imkoniyatini beradi.

Endi newScheduledThreadPool metodiga kelsak.

Uni bir necha usulda chaqirishimiz mumkin:

newScheduledThreadPool(int corePoolSize)

newScheduledThreadPool(int corePoolSize, ThreadFactory threadFactory)

Ikkala metod ham berilgan kechikishdan keyin yoki davriy bajarish uchun buyruqlarni rejalashtirishi mumkin bo'lgan iplar havzasini yaratadi.

Keling, ScheduledThreadPool ishini misol bilan ko'rib chiqaylik.

Masalan, har 5 soniyada pochtani tekshirish vazifasiga egamiz, garchi bu tekshiruv asosiy dastur ishiga ta'sir qilmasligi kerak va qo'shimcha resurslarni iste'mol qilish imkoniyati mavjud.

Bizda pochtani tekshirishni modellashtirgan vazifa sinfi mavjud.

public class Task implements Runnable {
   @Override
   public void run() {
       System.out.println("Pochtani tekshiryapmiz...");
   }
}

Keyin biz iplar havzasini yaratamiz va tekshiruv bajarilishini rejalashtiramiz.

ScheduledExecutorService executorService = Executors.newScheduledThreadPool(2);
executorService.scheduleAtFixedRate(new Task(), 0, 5, TimeUnit.SECONDS);

Har 5 soniyada natijada ko'rib turamiz:

Umuman, bunday hovuzni, misoldagidek, "servis" davriy vazifalarni bajarish uchun ishlatishimiz mumkin. Servis deb biz dastur asosiy funksiyasi ishlashidan qat'iy nazar bajarilishi kerak bo'lgan vazifalarni ataymiz.