Hogyan működnek az Executorok Java-ban?

Executor — ez egy interfész Java-ban, amely szerződést határoz meg feladatok végrehajtására egy szálkezelő csoportban. Ahelyett, hogy minden feladathoz külön szálakat hozna létre, a feladatokat a végrehajtóknak küldi, amelyek kezelik a szálak létrehozását, használatát és megsemmisítését.

Fő előnyei:

• Szálak kezelése: Egységes módot biztosít a szálak csoportjának kezelésére, elkerülve a manuális szálak létrehozását és szinkronizálását.
• Hatékonyság: Újrahasznosítja a meglévő szálakat, csökkentve a szálak létrehozásának és megsemmisítésének költségeit.
• Teljesítmény: Javítja az alkalmazások teljesítményét és reakciókészségét a feladatok aszinkron végrehajtásával.

A Executor-nak egy metódusa van:

// A megadott parancsot a jövőben egy időpontban hajtja végre.
void execute(Runnable command);

Gyakran használt altípusok:

• ExecutorService: Bővíti az Executor-t, és további módszereket kínál az végrehajtó életciklusának kezelésére és a feladatok eredményeinek lekérésére (pl. Future segítségével).
• ScheduledExecutorService: Bővíti az ExecutorService-t, és lehetővé teszi feladatok késleltetett vagy ütemezett végrehajtását.

Az Executors osztály gyári módszereket kínál különböző típusú végrehajtók létrehozására:

// Fix számú szállal rendelkező szálkezelő csoportot hoz létre.
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(5);

// Olyan szálkezelőt hoz létre, amely dinamikusan tudja szabályozni a szálak számát.
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();

// Olyan szálkezelőt hoz létre, amely feladatokat ütemezetten tud végrehajtani.
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);

Használati példa:

// Végrehajtó objektum
ExecutorService executor = Executors.newFixedThreadPool(2);

// Végrehajtandó feladat
Runnable task = new Runnable() {
    @Override
    public void run() {
        // Feladat kódja
        System.out.println("Feladat fut a szálban: " + Thread.currentThread().getName());
    }
};

// Feladat küldése a végrehajtónak
executor.execute(task);

// A végrehajtó leállítása (erőforrások felszabadításához szükséges)
executor.shutdown();

Amikor a execute() hívás megtörténik, a végrehajtó átveszi a feladatot (Runnable) és hozzárendeli egy szálhoz a végrehajtáshoz. A feladatok szétosztását és az életciklusukat a végrehajtó kezeli.