Mi az a szálakból álló pool?

Szálmedence (ThreadPool) — ez egy olyan munkás szálak csoportja, amelyet egy egységes entitás irányít, és amely feladatokat kap, majd elosztja azokat a rendelkezésre álló szálak között. Ahelyett, hogy minden feladathoz új szálat hozna létre, a medence újrahasznosítja a meglévőket.

Fő előnyei:

• Költségcsökkentés: A szálak létrehozása és megsemmisítése idő- és erőforrás-igényes. A medence ezt kiküszöböli.
• Erőforrás-kezelés: Korlátozza a párhuzamosan futó szálak maximális számát, megelőzve a rendszer erőforrásainak kimerülését.
• Teljesítmény növelése: Feladatok sorát kezeli, ami növelheti az alkalmazások áteresztőképességét.
• Könnyű kezelhetőség: Központosított mechanizmust biztosít aszinkron feladatok végrehajtására.

Java-ban a szálmedencék kezelésére a java.util.concurrent csomagot használják. Fő interfészek és osztályok:

• Executor: Feladatok végrehajtására szolgáló interfész.
• ExecutorService: Az Executor bővítése, amely módszereket kínál a medence életciklusának kezelésére és az eredmények lekérésére.
• Executors: Segédosztály a ExecutorService standard implementációinak létrehozásához, például:
  • newFixedThreadPool(int nThreads): Fix számú szálú medence.
  • newCachedThreadPool(): Olyan medence, amely szükség szerint hoz létre szálakat, és újrahasznosítja az inaktívakat.
  • newSingleThreadExecutor(): Egy szálú medence.
  • newScheduledThreadPool(int corePoolSize): Ütemezett feladatok végrehajtására szolgáló medence.
• ThreadPoolExecutor: Rugalmas ExecutorService implementáció, amely finomhangolhatóbbá teszi a medence viselkedését.

Példa az ExecutorService használatára:

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

// Feladat példa a medencében való végrehajtáshoz
class MyTask implements Runnable {
    private final int taskId;

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

    @Override
    public void run() {
        System.out.println("Feladat végrehajtása " + taskId + " szál által " + Thread.currentThread().getName());
        try {
            Thread.sleep(100); // Munka imitálása
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class ThreadPoolExample {
    public static void main(String[] args) {
        // Fix számú szálú medence létrehozása
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // Feladatok küldése végrehajtásra
        for (int i = 0; i < 10; i++) {
            executorService.submit(new MyTask(i));
        }

        // A medence helyes lezárása a feladatok befejezése után
        executorService.shutdown();
    }
}

A medence életciklusa a shutdown() és shutdownNow() metódusokkal kezelhető a helyes leállítás érdekében.