ThreadPoolExecutor के साथ कैसे रहते हैं?

Question

मेरे द्वारा पोस्ट किए गए question की निरंतरता में, मैं अपने कोडबेस में ThreadPoolExecutor का उपयोग करने का प्रयास कर रहा हूं। जावा एपीआई दस्तावेज़ से समझने के बार-बार प्रयास करने के बाद भी, मैं कन्स्ट्रक्टर में पास होने के लिए keepAliveTime पैरामीटर के पीछे कार्यक्षमता/उद्देश्य को स्पष्ट रूप से समझने में विफल रहा। उम्मीद है कि कोई मुझे कुछ अच्छे कामकाजी उदाहरण के साथ समझा सकता है।

अंशः जावा दस्तावेज़ से:

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

keepAliveTime - जब धागे की संख्या कोर से अधिक है, यह अधिक से अधिक समय है कि अतिरिक्त निष्क्रिय धागे नए कार्य के लिए इंतजार करेंगे है समाप्त करने से पहले।

Answer 1

मान लें कि आपके पास 5 का मूल आकार है, और अधिकतम आकार 15 है। किसी कारण से आपका पूल व्यस्त हो जाता है, और सभी 15 उपलब्ध धागे का उपयोग करता है। आखिर में आप काम करने से बाहर निकलते हैं - इसलिए आपके कुछ धागे निष्क्रिय हो जाते हैं क्योंकि वे अपना अंतिम कार्य पूरा करते हैं। तो उन धागे में से 10 को मरने की अनुमति है।

हालांकि, उन्हें बहुत जल्दी से मारने से बचने के लिए, आप जीवित समय निर्दिष्ट कर सकते हैं। इसलिए यदि आपने keepAliveTime मान और TimeUnit.MINUTEunit मान के रूप में 1 निर्दिष्ट किया है, तो प्रत्येक धागा यह देखने के लिए एक कार्य निष्पादित करने के एक मिनट बाद इंतजार करेगा कि यह देखने के लिए और अधिक काम है या नहीं। अगर इसे अभी भी कोई और काम नहीं दिया गया है, तो यह पूल में "कोर" - पूल में केवल 5 धागे होने तक ही खुद को पूरा कर देगा।

<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> 
* 

अनिवार्य रूप से यह केवल आपके धागे बेकार पूल में छोड़ दिया की संख्या को नियंत्रित करने के लिए अनुमति देता है:

Answer 2

यहाँ जावाडोक से कुछ और वर्णन है। यदि आप इसे बहुत छोटा करते हैं (आप जो कर रहे हैं उसके लिए), तो आप बहुत सारे धागे बनायेंगे। यदि आप इसे बहुत बड़ा बनाते हैं, तो आप स्मृति/थ्रेड का उपभोग करेंगे जिनकी आपको आवश्यकता नहीं है।

Answer 3

यहाँ कोड का उदाहरण है, जो का काम KeepAliveTime How does maximumPoolSize of ThreadPoolExecutor works?