Какво е пул от нишки?

Пул от потоци (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() за неговото коректно спиране.