Ի՞նչ է թելերի պուլը։

Թելեկոմպլեքս (ThreadPool) — դա աշխատանքային թելերի խումբ է, որը կառավարում է միավոր, որը ստանում է առաջադրանքներ և բաշխում դրանք հասանելի թելերին։ Փոխարենը ստեղծել նոր թել յուրաքանչյուր առաջադրանքի համար, պուլը դրանք վերօգտագործում է։

Հիմնական առավելությունները՝

• Արժեքների նվազեցում: Թելերի ստեղծումը և ոչնչացումը ժամանակատար և ռեսուրսային է։ Պուլը դա վերացնում է։
• Ռեսուրսների կառավարում: Մաքսիմալ միաժամանակ աշխատող թելերի քանակը սահմանափակում է, կանխելով համակարգային ռեսուրսների սպառումը։
• Արդյունավետության բարելավում: Կառավարում է առաջադրանքների հերթը, ինչը կարող է բարձրացնել ծրագրերի հոսքը։
• Կենտրոնացված կառավարման մեխանիզմ: Պատրաստում է կենտրոնական մեխանիզմ՝ ասինխրոն առաջադրանքների կատարման համար։

Java-ում թելերի պուլների հետ աշխատելու համար օգտագործվում է java.util.concurrent փաթեթը։ Հիմնական ինտերֆեյսներ և դասեր՝

• Executor: առաջադրանքների կատարման ինտերֆեյս։
• ExecutorService: Executor-ի ընդլայնում, որը տրամադրում է մեթոդներ պուլի կյանքի ցիկլի կառավարման և արդյունքների ստացման համար։
• Executors: օգնական դաս՝ ստանդարտ ExecutorService իրականացումների ստեղծման համար, օրինակ՝
  • newFixedThreadPool(int nThreads): ֆիքսված քանակությամբ թելերով պուլ։
  • newCachedThreadPool(): պուլ, որը ստեղծում է թելեր ըստ անհրաժեշտության և վերօգտագործում է անգործ թելերը։
  • newSingleThreadExecutor(): մեկ թելով պուլ։
  • newScheduledThreadPool(int corePoolSize): պուլ՝ ժամանակացույցով առաջադրանքների կատարման համար։
• ThreadPoolExecutor: ճկուն իրականացում ExecutorService-ի, որը թույլ է տալիս ավելի նուրբ կարգավորել պուլի վարքագիծը։

Օրինակ՝ ExecutorService-ի օգտագործումը՝

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

// Օրինակ առաջադրանք՝ կատարման պուլում
class MyTask implements Runnable {
    private final int taskId;

    public MyTask(int taskId) {
        this.taskId = taskId;
    }

    @Override
    public void run() {
        System.out.println("Կատարվում է առաջադրանք " + taskId + " թելով " + Thread.currentThread().getName());
        try {
            Thread.sleep(100); // Նմանատիպ աշխատանք
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class ThreadPoolExample {
    public static void main(String[] args) {
        // Ստեղծում է ֆիքսված քանակությամբ թելերով պուլ
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // Ուղարկում առաջադրանքներ կատարման
        for (int i = 0; i < 10; i++) {
            executorService.submit(new MyTask(i));
        }

        // Պուլը ճիշտ փակել՝ բոլոր առաջադրանքների ավարտից հետո
        executorService.shutdown();
    }
}

Պուլի կյանքի ցիկլը կառավարում է shutdown() և shutdownNow() մեթոդներով՝ դրա ճիշտ կանգնեցնելու համար։