Однако иногда я хотел бы, чтобы увеличить или уменьшить количество потоков, запущенные в то же время для того, чтобы точно настроить Perfomance из приложения (без перезапуска приложения или убийства любых запущенных тема).
Если вы имеете в виду динамическое изменение с помощью какого-либо инструмента или чего-то другого, то я не уверен, но вы можете поставить некоторую логику кода для управления.
Вы можете использовать java.util.concurrent.ThreadPoolExecutor и использовать CorePoolSize и MaxPoolSize свойства, чтобы иметь контроль над пул потоков.
corePoolSize и maximumPoolSize:
- ThreadPoolExecutor будет автоматически регулировать размер пула (см getPoolSize()) в соответствии с границами, установленными corePoolSize (см getCorePoolSize()) и maximumPoolSize (см getMaximumPoolSize()).
- Когда новая задача отправляется при выполнении метода (java.lang.Runnable), и выполняется меньше потоков corePoolSize, для обработки запроса создается новый поток, даже если другие рабочие потоки простаивают.
- Если существует больше, чем corePoolSize, но меньше потоков MaximumPoolSize, новый поток будет создан только в том случае, если очередь заполнена.
Однако прежде чем вы решите, я бы рекомендовал прочитать ниже выдержки из документов Java от ThreadPoolExecutor.
Однако программистов настоятельно рекомендуются использовать более удобные исполнитель фабричных методов Executors.newCachedThreadPool() (неограниченный поток бассейна, с автоматической мелиоративных резьбой), Executors.newFixedThreadPool (INT) (фиксированные size thread pool) и Executors.newSingleThreadExecutor() (одиночный фоновый поток), который предустановляет настройки для наиболее распространенных сценариев использования.
Пример кода:
см ниже примере кода. Большинство вещей вы можете понять, прочитав код и просматривая документы Java. Тем не менее, то, что не может быть очевидным является тот факт, что
- мы использовали
ArrayBlockingQueue для получение ограниченной очереди 20 емкости (вы можете принять решение о емкости очереди согласно вашему требованию). Итак, как только в очереди будет запущено более 20 задач, будут созданы новые потоки, но до максимума maxPoolSize.
- Основываясь на нагрузке, мы увеличиваем количество потоков пулов ядра, что означает, что больше потоков будет обрабатывать ваши задачи, поэтому шансы на получение очередей задач меньше. Но вы также можете играть с maxPoolSize.
Вы можете прочитать раздел «Очередь» ThreadPoolExecutor и решить другую очередь, согласно вашему требованию.
ThreadPoolExecutor.setCorePoolSize(int)
Устанавливает число сердечников резьбы. Это переопределяет любое значение, заданное в конструкторе. Если новое значение меньше текущего значения, превышение существующих потоков будет прекращено, когда они станут свободными. Если больше, новых потоков, при необходимости, начнется выполнение любых задач в очереди.
//Read Java docs for details about construcutor...
ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(10, 100, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(20));
Runnable runnable = new Runnable() {
@Override
public void run() {
//Do your task...
}
};
executeTasks(poolExecutor, runnable, false, false); //Compute last 2 parameters as you need and pass on required values.
public static void executeTasks(ThreadPoolExecutor poolExecutor, Runnable runnable, boolean isUnderLoad, boolean isOverLoad){
if(isOverLoad && isUnderLoad){
//Handle this situation, this should not be allowed, probably a coding bug can result this...
}
poolExecutor.submit(runnable);
if(isUnderLoad){
poolExecutor.setCorePoolSize(5);
}
if(isOverLoad){
poolExecutor.setCorePoolSize(20);
}
}
'ThreadPoolExecutor' с гибким размером, вы можете сделать это –