ThreadPoolExecutor

Когато разработваме многонишково приложение, обикновено трябва да се занимаваме с организиране на работата на нишките. Колкото по-голямо е нашето приложение и колкото повече нишки са ни необходими за многонишкови задачи, толкова повечеРаботимобекти, които създаваме.

Тук трябва да се отбележи, че създаването на нишка в Java е доста скъпа операция. Ако създаваме нов екземпляр на нишката всеки път, за да извършим операция, ще имаме големи проблеми с производителността и в резултат на това със здравето на приложението.

Тук на помощ ни идват пул от нишки и ThreadPoolExecutor .

Пулът от нишки е набор от предварително инициализирани нишки. Размерът му може да бъде фиксиран or променлив.

Ако има повече задачи, отколкото нишки, тогава задачите чакат в опашка със задачи. N-тата нишка в пула взема задача от опашката и след като тя бъде изпълнена, нишката взима нова задача от опашката. След като всички задачи в опашката бъдат изпълнени, нишките остават активни и чакат нови задачи. Когато се появят нови задачи, нишките също започват да ги изпълняват.

ThreadPoolExecutor

Започвайки с Java 5, рамката Executor придоби многопоточно решение. Като цяло има много компоненти и целта му е да ни помогне да управляваме ефективно опашки и пулове от нишки.

Основните интерфейси са Executor и ExecutorService .

Executor е интерфейс с един метод void execute (Runnable runnable).

Когато предавате задача на имплементация на този метод, знайте, че тя ще се изпълнява асинхронно в бъдеще.

ExecutorService — Интерфейс, който разширява интерфейса на Executor , добавяйки възможности за изпълнение на задачи. Той също така има методи за прекъсване на изпълнявана задача и прекратяване на пула от нишки.

ThreadPoolExecutor имплементира интерфейсите Executor и ExecutorService и разделя създаването на задача от изпълнението на задача. Трябва да внедрим Runnable обекти и да ги изпратим на изпълнител. След това ThreadPoolExecutorе отговорен за изпълнението на задачите и създаването и работата с нишки .

След изпращане на задача за изпълнение се използва съществуваща нишка в пула. Това подобрява производителността. Той решава проблема с губенето на ресурси за създаване и инициализиране на нова нишка и след това отново за събиране на боклук, след като приключим с нишката.

ThreadPoolExecutor има 4 конструктора:

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit, 
BlockingQueue<Runnable> workQueue)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory, 
RejectedExecutionHandler handler)
    

Конструкторът ThreadPoolExecutor има следните параметри:

Създаване на ThreadPoolExecutor

Класът на помощната програма Executors може да опрости създаването на ThreadPoolExecutor . Методите на този полезен клас ни помагат да подготвим aThreadPoolExecutorобект.

ExecutorService executor = Executors.newFixedThreadPool(10);
                    

ExecutorService executor = Executors.newWorkStealingPool(4);
                    

ExecutorService executor = Executors.newSingleThreadExecutor();
                    

ExecutorService executor = Executors.newCachedThreadPool();
                    

ScheduledExecutorService executor = Executors.newScheduledThreadPool(10);
                    

Ще разгледаме всеки тип басейн в следващите уроци.