Коллеги, подскажите, пожалуйста. ThreadPoolExecuter инициализируется LinkedBlockingQueue и размером corePool=maxPool равный 1,

Question

Коллеги, подскажите, пожалуйста. ThreadPoolExecuter инициализируется LinkedBlockingQueue и размером corePool=maxPool равный 1,

затем(в зависимости отнагрзуки устанавливается большее количество потоков)
И него накидываются Runnable для выполнения.
Ожидается, что пока есть количество потоков меньше, чем maximumPoolSize ThreadPoolExecutor создаёт новые потоки и и берёт задачи на выполнение. Как только количество потоков становится равно maximumPoolSize, то все задачи складываются в очередь. И затем освободившиеся потоки их от туда забирают.
В большинстве случаев это так и работает, но стаблино раз несколько дней мы получаем ситуацию, когда maximumPoolSize=corePoolSize=100, workQueue=»100 (мого больше к примеру 3500), а workers = 2 и при этом попытки создать новые потоки, чтобы разгребать очередь не происходят.
В какую сторону копать?

#backend #java #programming #russian

0

25.09.2019

1 ответов

1 просмотр

Aleksey Shipilev · Accepted Answer

javadoc на ThreadPoolExecutor читали? Там написано, что при #current < #core создастся поток, иначе задачу положат в очередь. При #core <= #current < #max, TPE создаст поток только тогда, когда очередь режектнет задачу (что в случае LinkedBlockingQueue может и не произойти). Если задачи таким образом оказались уже в очереди, то по контракту setCorePoolSize должен бы развернуть больше воркеров. Этого не случилось, так? Тогда это баг в TPE.

170 похожих чатов

Коллеги, подскажите, пожалуйста. ThreadPoolExecuter инициализируется LinkedBlockingQueue и размером corePool=maxPool равный 1,

1 ответов

Похожие вопросы