Jak działa Keep-alive z ThreadPoolExecutor?

Question

W kontynuacji do question zamieszczonych przeze mnie, próbuję użyć ThreadPoolExecutor w mojej bazie kodów. Nawet po wielokrotnych próbach zrozumienia z dokumentu Java API nie udało mi się jasno zrozumieć funkcji/celu parametru keepAliveTime do przekazania w konstruktorze. Mam nadzieję, że ktoś może mi wytłumaczyć dobrym przykładem.

Fragmenty Java Doc:

public ThreadPoolExecutor(int corePoolSize, 
          int maximumPoolSize, 
          long keepAliveTime, 
          TimeUnit unit, 
          BlockingQueue<Runnable> workQueue) 

keepAliveTime - gdy liczba wątków jest większa niż rdzeń, to maksymalny czas, że nadmiar nici idle będzie czekać na nowe zadania przed zakończeniem.

Answer 1

Załóżmy, że masz rozmiar rdzenia 5 i maksymalny rozmiar 15. Z jakiegoś powodu twój basen jest zajęty i używa wszystkich 15 dostępnych wątków. W końcu zabraknie ci pracy - niektóre z twoich wątków stają się bezczynne, kiedy kończą swoje ostatnie zadanie. Tak więc 10 z tych wątków może umrzeć.

Jednak, aby uniknąć ich zbytniego zabicia, można określić czas pozostawania przy życiu. Jeśli podasz 1 jako wartość keepAliveTime i TimeUnit.MINUTE jako wartość unit, każdy wątek będzie czekać jedną minutę po zakończeniu wykonywania zadania, aby sprawdzić, czy jest więcej pracy do wykonania. Jeśli jeszcze nie otrzymałoby się więcej pracy, pozwoliłoby to na ukończenie, dopóki w puli nie byłoby tylko 5 wątków - "rdzenia" puli.

Answer 2

Oto kilka opis z Javadoc:

<dt>Keep-alive times</dt> 
* 
* <dd>If the pool currently has more than corePoolSize threads, 
* excess threads will be terminated if they have been idle for more 
* than the keepAliveTime (see {@link 
* ThreadPoolExecutor#getKeepAliveTime}). This provides a means of 
* reducing resource consumption when the pool is not being actively 
* used. If the pool becomes more active later, new threads will be 
* constructed. This parameter can also be changed dynamically 
* using method {@link ThreadPoolExecutor#setKeepAliveTime}. Using 
* a value of <tt>Long.MAX_VALUE</tt> {@link TimeUnit#NANOSECONDS} 
* effectively disables idle threads from ever terminating prior 
* to shut down. 
* </dd> 
* 

Zasadniczo to właśnie pozwala kontrolować liczbę wątków pozostawione w bezczynności basenie. Jeśli uczynisz to zbyt małym (dla tego, co robisz), będziesz tworzyć zbyt wiele wątków. Jeśli zrobisz to za duże, zużyjesz pamięć/wątki, których nie potrzebujesz.

Answer 3

Oto przykład kodu, który pokazuje pracę KeepAliveTime How does maximumPoolSize of ThreadPoolExecutor works?