newCachedThreadPool Metodi

Yana bir turdagi oqimlar havzasi - keshlangan. Bu oqimlar havzalari ham xuddi qayd etilganlar kabi keng qo'llaniladi.

Oqimlar havzasi oqimlarni keshlaydi, shuning uchun nomlanishi shunday. U oqimlarni (lekin ishlatilmayotganini) o'z vaqtida faol ravishda saqlaydi, bu oqimlardan yangi vazifalarni bajarishda foydalanish uchun. Bunday oqimlar havzasini eng yaxshi ishlatish tavsiya etiladi, agar bizda bajarish uchun ma'lum bir me'yorda yengil vazifalar bo'lsa.

“Ma'lum bir me'yordan” tushunish ancha keng bo'lishi mumkin, lekin bunday havza har bir vazifalar soniga mos kelmasligini tushunish kerak. Masalan, biz millionta vazifa yaratmoqchi bo'lsak, ular juda kam vaqt oladigan bo'lsa-da, baribir, resurslarni nojo'ya ishlatamiz va ishlashni yomonlashtiramiz. Shuningdek, biz bunday havzadan foydalanishdan qochishimiz kerak, agar bajarish vaqti oldindan aytilmagan bo'lsa, masalan, kiritish-chiqarish vazifalarida.

“Kaput” ostida quyidagi parametrlarga ega ThreadPoolExecutor konstruktor chaqiriladi:

public static ExecutorService newCachedThreadPool() {
    // Boshqa kodlar
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, 
      new SynchronousQueue<Runnable>());
}

Konstruktor uchun quyidagi parametrlar beriladi:

Biz ham ThreadFactory turidagi o'zimizning amalga oshirgan obyektimizni parametr sifatida berishimiz mumkin.

SynchronousQueue haqida gaplashamiz

Sinxron uzatishning asosiy g'oyasi juda sodda va ayni paytda intuitiv emas (bu hissiyot, sog'lom fikr yoki his-tuyg'ularga asoslanib baholanganida haqiqiy ko'rinmaydi): elementni faqat boshqa oqim bu elementni bir vaqtning o'zida qabul qilayotganda navbatga qo'yish mumkin. Boshqacha aytganda, sinxron navbat ichida vazifalar bo'la olmaydi, chunki yangi vazifa kelganda, bajaruvchi oqim allaqachon bu vazifani olishadi.

Yangi vazifa navbatga kelganda, agar havzada bo'sh faol oqim mavjud bo'lsa, u bu vazifani oladi, agar barcha oqimlar band bo'lsa - yangi oqim yaratiladi.

Keshlangan havza nol oqimdan boshlanadi va potentsial ravishda Integer.MAX_VALUE ga teng oqimlar sonigacha o'sishi mumkin. Keshlangan oqimlar havzasi uchun deyarli yagona cheklov tizim resurslaridir.

Tizim resurslarini boshqarish uchun keshlangan oqimlar havzalari bir daqiqa davomida ishdan turgan oqimlarni yo'q qiladi.

Keling, buni amalda qanday ishlashini tekshiramiz. Biz vazifa klasi yaratamiz, foydalanuvchi so'rovini modellashtiramiz:

public class Task implements Runnable {
   int taskNumber;
   
   public Task(int taskNumber) {
       this.taskNumber = taskNumber;
   }
   
   @Override
   public void run() {
       System.out.println("Foydalanuvchi so'rovi №" + taskNumber + " oqimda qayta ishlangan " + Thread.currentThread().getName());
   }
}
    

main da biz newCachedThreadPool yaratamiz va 3ta vazifani bajarishga qo'shamiz. Bu yerda xizmatimizning statusini chiqaramiz (1).

Keyin 30 soniyaga pauza qilamiz, shundan so'ng yana bir vazifani bajarishga qo'yib, statusni chiqaramiz (2).

Bundan keyin asosiy oqimimizni 70 soniyaga to'xtatamiz, statusni chiqaramiz (3) va yana 3ta vazifani bajarishga qo'shamiz va statusni yana chop etamiz (4).

Vazifalarni qo'shgandan keyin, statuslar chiqariladigan joylarda, biz sleep ni 1 soniyaga qo'yamiz, aniq chiqish uchun.

ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < 3; i++) {
            executorService.submit(new Task(i));
        } 

        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(1)
        
        TimeUnit.SECONDS.sleep(30);
        
        executorService.submit(new Task(3));
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(2)

        TimeUnit.SECONDS.sleep(70);
        
            System.out.println(executorService);	//(3)
        
        for (int i = 4; i < 7; i++) {
            executorService.submit(new Task(i));
        }  
        
        TimeUnit.SECONDS.sleep(1);
            System.out.println(executorService);	//(4)
        executorService.shutdown();

Shunday qilib, natija:

Har bir qadamni tahlil qilamiz:

Shu tariqa, biz oqimlarni boshqarish bilan yana bir turdagi xizmat bilan tanishdik.

Executors sinfining boshqa yordamchi metodlariga o'xshash, newCachedThreadPool metodining ham o'z variantlari bor, qaysi parametr sifatida ThreadFactory turidagi obyektni qabul qiladi.