Может ли размер workQueue быть больше, чем maximumPoolSize?

Question

Мы ThreadPoolExecutor и его инициализация выглядит следующим образом:

LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(); 
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(maxThreads, maxThreads, 50000L, TimeUnit.MILLISECONDS, queue); 

И значение maxThreads 200, но приходит время, когда queue.size()> 200. Почему это может быть?

Answer 1

corePoolSize или maximumPoolSize определяет размер бассейна, это размер BlockingQueue, который имеет значение.

Вы используете LinkedBlockingQueue, это основано на связанной структуре и имеет максимальный размер по умолчанию Integer.MAX_VALUE. Она также позволяет изменить его максимальный размер, используя конструктор, передавая требуемый размер, например:

LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(200); 

Передавая 200 в своем конструкторе, вам бассейн будет держать максимум 200 задач

Answer 2

maxThreads представляет максимальное количество объединенных потоков. Ваш размер очереди представляет собой количество заданных в очереди задач, ожидающих выполнения.