Kas yra sriegių baseinas?

Gijų siūlomas (ThreadPool) yra darbo srautų grupė, kurią valdo vienas subjektas, gaunantis užduotis ir paskirstantis jas tarp prieinamų srautų. Vietoj to, kad kiekvienai užduočiai sukurtų naują srautą, baseinas juos pakartotinai naudoja.

Pagrindiniai privalumai:

• Mažesnės išlaidos: Srautų kūrimas ir naikinimas yra laiko ir išteklių sąnaudų reikalaujantis procesas. Baseinas tai pašalina.
• Išteklių valdymas: Ribojamas maksimalus vienu metu veikiančių srautų skaičius, užkertant kelią sisteminių išteklių išnaudojimui.
• Veiklos gerinimas: Valdo užduočių eilę, kas gali padidinti programų pralaidumą.
• Valdymo patogumas: Suteikia centralizuotą mechanizmą asinchroninių užduočių vykdymui.

Java kalboje darbui su siūlų baseinais naudojamas java.util.concurrent paketas. Pagrindiniai sąsajos ir klasės:

• Executor: užduočių vykdymo sąsaja.
• ExecutorService: Executor plėtinys, teikiantis metodus siūlų baseino gyvavimo ciklo valdymui ir rezultatų gavimui.
• Executors: pagalbinė klasė standartinėms ExecutorService įgyvendinimams kurti, pavyzdžiui:
  • newFixedThreadPool(int nThreads): su fiksuotu siūlų skaičiumi baseinas.
  • newCachedThreadPool(): baseinas, kuris kuria siūlus pagal poreikį ir juos pakartotinai naudoja.
  • newSingleThreadExecutor(): vieno siūlo baseinas.
  • newScheduledThreadPool(int corePoolSize): planuotas užduočių vykdymas.
• ThreadPoolExecutor: lanksti ExecutorService įgyvendinimas, leidžiantis detaliau reguliuoti baseino elgesį.

Pavyzdys naudojant ExecutorService:

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

// Pavyzdinė užduotis, vykdoma baseine
class MyTask implements Runnable {
    private final int taskId;

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

    @Override
    public void run() {
        System.out.println("Vykdoma užduotis " + taskId + " siūlu " + Thread.currentThread().getName());
        try {
            Thread.sleep(100); // Darbo imitacija
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class ThreadPoolExample {
    public static void main(String[] args) {
        // Sukuriamas fiksuoto siūlų skaičiaus baseinas
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // Užduočių siuntimas vykdymui
        for (int i = 0; i < 10; i++) {
            executorService.submit(new MyTask(i));
        }

        // Teisingas baseino užbaigimas po visų užduočių įvykdymo
        executorService.shutdown();
    }
}

Baseino gyvavimo ciklas valdomas shutdown() ir shutdownNow() metodais, siekiant teisingai jį sustabdyti.