ThreadPoolExecutor — использовать потоки перед очередью ⇐ JAVA

[Anonymous]

Я заменяю устаревший пул потоков на Java с учетом ThreadPoolExecutor.
В устаревшем пуле потоков при запуске создается 600 потоков. Но в ThreadPoolExecutor, используя концепцию основных потоков, максимального количества потоков и prestartAllCoreThreads(), количество потоков при запуске может быть ограничено.
Теперь
< ol>
[*]Если запущено меньше потоков, чем corePoolSize, Исполнитель предпочитает добавить новый поток, а не ставить в очередь.
[*]Если запущено ядроPoolSize или несколько потоков, Исполнитель предпочитает постановка запроса в очередь, а не добавление нового потока.
Если запрос не может быть поставлен в очередь, создается новый поток, если только он не превысит максимальный размер пула, и в этом случае задача будет отклонена.< /li>

Первый сценарий — это нормально, но я хочу, чтобы использовались основные потоки, а не ставили задачи в очередь (даже в случае ограниченной очереди, скажем, размер 100) и ожидая, пока основные потоки будут простаивать или заполнится очередь, новый поток будет создан из квоты неосновного пула. Как и в режиме реального времени, мое приложение не выдерживает идеи ожидания задачи в очереди.
поэтому мне нужен CoreThreads -> Non-CoreThreads -> Queue вместо CoreThreads -> Queue -> Non-CoreThreads.
т.е. если используются основные потоки, создайте новые потоки, а если размер пула максимальный, то задача должна поставиться в очередь и ждать, пока какой-либо поток освободится. .
Один из способов сделать это — расширить класс ThreadPoolExecutor и переопределить метод выполнения, но тогда мне придется практически скопировать класс целиком. Это грязный способ, о котором я мог подумать. Может ли кто-нибудь предложить какой-либо другой способ.
Примечание: я не могу использоватьcachedThreadPool, так как количество потоков должно быть ограничено.

Подробнее здесь: https://stackoverflow.com/questions/192 ... fore-queue