Использование ExecutorService/ThreadPool для простого списка переменных всегда активных потоков

Question

Я обсуждал, есть ли смысл использовать ExecutorService для простого, динамически растущего списка потоков одного и того же класса, все из которых всегда активны. Я понимаю, что Executors.newFixedThreadPool(int) предоставляет пул потоков, который может содержать любое количество потоков, но только номер, указанный в методе, активен в любой момент времени. У меня нет такого ограничения, IOW, если я добавлю 6 потоков, я хочу, чтобы все 6 выполнялись одновременно.

Должен ли я использовать фреймворк Executors, если есть какие-то преимущества для его использования, или просто поместить мои потоки в ArrayList?

Answer 1

Должен ли я использовать фреймворк Executors, если есть преимущества для его использования, или я должен просто поместить свои потоки в ArrayList?

Много людей развивают и управляют своими потоками. Тем не менее, основная причина, почему классы ExecutorService настолько сильно рекомендованы, так это то, что они заботятся об управлении потоками и связанными с ними задачах и уменьшают количество кода, который вы должны писать, отлаживать, поддерживать. Очевидно, они предоставляют множество других функций, таких как поддержка Callable, услуги по завершению и т. Д., Которые вы не можете использовать. Но оставить управление этими основными классами, даже для простого проекта, само по себе хорошо. Я использую их даже для однопоточных пулов, потому что я хочу, чтобы функции очереди задач Runnable пула потоков вместо того, чтобы писать собственный BlockingQueue или другой механизм.

если я добавляю 6 потоков, я хочу, чтобы все 6 работали одновременно.

Тогда вы должны использовать Executors.newCachedThreadPool(). Если вы отправите 6 заданий (экземпляр Runnable или Callable), то через него начнут обрабатываться 6 потоков. Если 3 задания заканчиваются и другие задания подаются, тогда 3 неактивных потока будут запускать другие задания.

ПРИМЕЧАНИЕ: если вы отправляете 1000 заданий, вы начнете 1000 потоков, которые, скорее всего, не, что вы хотите сделать.

---

Например, чтобы написать это самостоятельно будет принимать гораздо больше код:

// a pool of 10 threads 
ExecutorService threadPool = Executors.newFixedThreadPool(10); 
// submit a bunch of jobs to they 10 threads for processing 
for (MyJob job : jobsToDo) { 
    threadPool.submit(job); 
} 
// no more tasks are being submitted so shutdown the pool 
threadPool.shutdown(); 
// wait for the jobs to finish 
threadPool.awaitTermination(Long.MAX_VALUE, TimeUnit.MILLISECONDS);