Kas ir pavedienu baseins?

Darbības pavedieni (ThreadPool) ir darba pavedienu grupa, ko pārvalda viena vienība, kas saņem uzdevumus un sadala tos starp pieejamajiem pavedieniem. Tā vietā, lai katram uzdevumam izveidotu jaunu pavedienu, baseins tos atkārtoti izmanto.

Galvenās priekšrocības:

• Izmaksu samazināšana: Pavedienu izveide un iznīcināšana ir laika un resursu prasīga. Baseins to novērš.
• Resursu pārvaldība: Ierobežo maksimālo vienlaicīgi darbojošo pavedienu skaitu, novēršot sistēmas resursu izsīkšanu.
• Veiktspējas uzlabošana: Pārvalda uzdevumu rindu, kas var palielināt lietojumprogrammu caurlaidību.
• Vienkārša pārvaldība: Nodrošina centralizētu mehānismu asinhrono uzdevumu izpildei.

Java valodā ar pavedienu baseiniem strādā ar java.util.concurrent paketi. Galvenās saskarnes un klases:

• Executor: uzdevumu izpildes saskarne.
• ExecutorService: Executor paplašinājums, kas nodrošina metodes baseina dzīves cikla pārvaldībai un rezultātu iegūšanai.
• Executors: palīgklase standarta ExecutorService realizāciju izveidei, piemēram:
  • newFixedThreadPool(int nThreads): ar fiksētu pavedienu skaitu baseins.
  • newCachedThreadPool(): baseins, kas izveido pavedienus pēc nepieciešamības un atkārtoti izmanto neaktīvos.
  • newSingleThreadExecutor(): ar vienu pavedienu baseins.
  • newScheduledThreadPool(int corePoolSize): plānotu uzdevumu izpilde.
• ThreadPoolExecutor: elastīga ExecutorService realizācija, kas ļauj smalkāk pielāgot baseina uzvedību.

Piemērs ar ExecutorService:

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

// Piemērs uzdevumam, kas tiek izpildīts baseinā
class MyTask implements Runnable {
    private final int taskId;

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

    @Override
    public void run() {
        System.out.println("Uzdevums tiek izpildīts " + taskId + " pavedienā " + Thread.currentThread().getName());
        try {
            Thread.sleep(100); // Darba imitācija
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

public class ThreadPoolExample {
    public static void main(String[] args) {
        // Izveido fiksētu pavedienu skaitu baseinu
        ExecutorService executorService = Executors.newFixedThreadPool(3);

        // Sūta uzdevumus izpildei
        for (int i = 0; i < 10; i++) {
            executorService.submit(new MyTask(i));
        }

        // Pareizi aizver baseinu pēc visu uzdevumu pabeigšanas
        executorService.shutdown();
    }
}

Baseina dzīves cikls tiek pārvaldīts ar shutdown() un shutdownNow() metodēm, lai to pareizi apturētu.