ExecutorService interfeysi

Executor interfeysining maqsadi

Java 5'ga qadar oqimlarni boshqarish uchun butun kodni o'zingiz yozishingiz kerak edi. Bundan tashqari, new Thread obyektini yaratish — bu resurs talabi yuqori bo'lgan operatsiya, va “yengil vaznli” vazifalar uchun har safar yangi oqim yaratish mantiqli emas edi. Va chunki bu muammoga ko'p oqimli ilovalarni ishlab chiquvchilar duch kelgan, bu funksiyani Java'da Executor freymvorki sifatida ajratishga qaror qildilar.

Asosiy g'oya nima? Juda oddiy: har bir yangi vazifa uchun yangi oqim yaratish o'rniga, oqimlar qandaydir "xotira"da saqlanadi va yangi vazifa kelganda, mavjud oqim olinadi, yangi yaratilmaydi.

Ushbu freymvorkning asosiy interfeyslari — Executor, ExecutorService va ScheduledExecutorService, har biri avvalgisidan ko'proq imkoniyatga ega.

Executor interfeysi — bu asosiy interfeys bo'lib, faqat bitta metodni e'lon qiladi: void execute(Runnable command) — vazifani ishga tushirish uchun, u Runnable tipidagi obyekt bilan ta'riflanadi.

ExecutorService interfeysi esa qiziqarliroq, chunki bu interfeysda ishni tugatishni boshqarish uchun metodlar mavjud va ba'zi resultatlarni qaytaradigan metodlar ham bor. Uning metodlari yanada batafsil:

Keling, ExecutorService bilan ishlashning kichik bir misolini ko'rib chiqamiz.

import java.util.List;
import java.util.concurrent.*;

public class ExecutorServiceTest {
   public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
// 2 oqimlik ExecutorService yaratamiz
       java.util.concurrent.ExecutorService executorService = new ThreadPoolExecutor(2, 2, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10));
// 5 ta vazifa yaratamiz
       MyRunnable task1 = new MyRunnable();
       MyRunnable task2 = new MyRunnable();
       MyRunnable task3 = new MyRunnable();
       MyRunnable task4 = new MyRunnable();
       MyRunnable task5 = new MyRunnable();

       final List<MyRunnable> tasks = List.of(task1, task2, task3, task4, task5);
// 5 ta oldin yaratilgan vazifalarni o'z ichiga olgan ro'yxatni qayta ishlash uchun yuboramiz
       final List<Future<Void>> futures = executorService.invokeAll(tasks, 6, TimeUnit.SECONDS);
       System.out.println("got futures");

// ExecutorService ni to'xtatamiz
       executorService.shutdown();

       try {
           TimeUnit.SECONDS.sleep(3);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }

       System.out.println(executorService.isShutdown());
       System.out.println(executorService.isTerminated());
   }

   public static class MyRunnable implements Callable<Void> {

       @Override
       public Void call() {
// 2 ta vaqt kechikishini qo'shamiz. ExecutorService ni to'xtatishda vazifa bajarishni to'xtatishga urinishda qaysi ulardan biri ishlayotganini ko'ramiz
           try {
               TimeUnit.SECONDS.sleep(3);
           } catch (InterruptedException e) {
               System.out.println("sleep 1: " + e.getMessage());
           }
           try {
               TimeUnit.SECONDS.sleep(2);
           } catch (InterruptedException e) {
               System.out.println("sleep 2: " + e.getMessage());
           }
           System.out.println("done");
           return null;
       }
   }
}

Dastur chiqishi:

Har bir vazifa 5 sekund davom etadi. Ikkita oqimli pool yaratganimiz uchun dastlabki ikkita chiziq aniq va tushunarli.

Dastur ishga tushganidan 6 sekund o'tgach, invokeAll metodining taym-auti sodir bo'ladi va Future ro'yxati sifatida natija qaytariladi. Bu "got futures" chizig'i chiqishini ko'rsatadi.

Birinchi ikkita vazifa yakunlangandan so'ng, yana ikkita vazifa ishlay boshladi. Lekin metodda ko'rsatilgan vaqt o'tgani uchun invokeAll, bu ikkita vazifa tugashga ulgursalari, "bekor" buyruqini olishdi. Shu sababli chiqishlarda ikkita satr “sleep 1: sleep interrupted” ko'rinadi.

Keyin yana ikkita “done” yozuvini ko'rishimiz mumkin. Bu invokeAll metodini ta'riflashda yozgan yon ta'sir ko'rsatmasining namunasidir.

Beshinchi vazifa umuman ishga tushmagan, shuning uchun biz dastur chiqishida u haqida hech narsa ko'rmaymiz.

Oxirgi ikki qator - bu isShutdown va isTerminated metodlari chaqiruvining natijalarini ko'rsatadi.

Ushbu misolda taym-autning tugashidan so'ng (kodni "executorService.shutdown();") qatorida brekpoint qo'yib, vazifalarning holatini debagda ko'rishga qiziq:

Ko'rib turibmizki, ikkita vazifa tugadi: "Completed normally", va uchta vazifa "Cancelled".

ScheduledExecutorService

Ekzekyutorlar haqida hikoyani yakunlash uchun, ScheduledExecutorService haqida ham gaplashamiz.

Bu interfeysda 4 ta metod mavjud: