जावा में मल्टीथ्रेडिंग: एक्सेकॉर्स सर्विस

जावा 5 में, मल्टीथ्रेडिंग को व्यवस्थित करने के लिए और विशेष रूप से समानांतर पहुंच के संगठन के संबंध में बहुत सी चीजें जोड़ी गईं। इस और बाद के लेखों में, हम उनमें से कुछ पर जाएंगे।

ExecutorService

जावा 5 से पहले, कई थ्रेड्स के साथ काम को व्यवस्थित करने के लिए, आपको तीसरे पक्ष के पूलिंग कार्यान्वयन का उपयोग करना होगा या अपना खुद का लिखना होगा। ExecutorService के आगमन के साथ ExecutorService यह आवश्यकता गायब हो गई है।

ExecutorService एक या अधिक थ्रेड्स में एसिंक्रोनस कोड निष्पादित करता है। एक ExecutorService उदाहरण बनाना या तो विशिष्ट कार्यान्वयन ( ScheduledThreadPoolExecutor या ThreadPoolExecutor ) के माध्यम से मैन्युअल रूप से किया जाता है, लेकिन यह Executors वर्ग के कारखानों का उपयोग करना आसान होगा। उदाहरण के लिए, यदि आपको 2 थ्रेड्स के साथ एक पूल बनाने की आवश्यकता है, तो यह इस तरह से किया जाता है:

ExecutorService service = Executors.newFixedThreadPool(2);

यदि आप थ्रेड्स के कैशिंग पूल का उपयोग करना चाहते हैं, जो कि आवश्यकतानुसार थ्रेड बनाता है, लेकिन निष्क्रिय थ्रेड्स का पुन: उपयोग करता है (और कुछ समय के लिए निष्क्रिय किए गए थ्रेड्स को साफ करता है), तो यह निम्नानुसार सेट किया गया है:

ExecutorService service = Executors.newCachedThreadPool();

अब एक छोटा सा उदाहरण। मान लें कि आपको 10 बार एसिंक्रोनस रूप से कुछ कोड चलाने की आवश्यकता है। उपरोक्त के आधार पर, कोड इस तरह दिखेगा:

ExecutorService service = Executors.newCachedThreadPool();
for ( int i = 0; i < 10; i++) {
service.submit( new Runnable() {
public void run() {
// snip... piece of code
}
});
}


submit विधि एक Future ऑब्जेक्ट को भी लौटाती है, जिसमें पास की गई Runnable या Callable (जो मान लौटा सकती है) के निष्पादन की स्थिति के बारे में जानकारी होती है। इससे, आप यह पता लगा सकते हैं कि प्रेषित कोड सफल था, या यदि यह अभी भी निष्पादित किया जा रहा है। Future ऑब्जेक्ट पर get विधि को कॉल करने get एक वैल्यू वापस आ जाएगी जो कि Callable (या Runnable उपयोग होने पर null ) को वापस कर देती है। विधि 2 अपवादों की जाँच की है: InterruptedException , जिसे फेंक दिया जाता है जब निष्पादन में interrupt() विधि, या ExecutionException माध्यम से interrupt() यदि Runnable या Callable में कोड RuntimeException Callable RuntimeException , जो थ्रेड्स के बीच अपवाद अपवादों की समस्या को हल करता है।

ScheduledExecutorService

कभी-कभी कोड को एसिंक्रोनस रूप से और समय-समय पर निष्पादित करना आवश्यक होता है या कुछ समय बाद कोड को निष्पादित करने की आवश्यकता होती है, फिर ScheduledExecutorService एक्सिक्यूटर सेवा से बचाव के लिए आता है। यह आपको एक या अधिक थ्रेड्स में कोड डालने और अंतराल या समय को कॉन्फ़िगर करने की अनुमति देता है जिसके लिए निष्पादन में देरी होगी। अंतराल लगातार दो के बीच का समय हो सकता है या एक रन के अंत और दूसरे की शुरुआत के बीच का समय हो सकता है। ScheduledExecutorService विधियाँ ScheduledExecutorService वापस करती हैं, जिसमें ScheduledFuture फ़ॉउल को निष्पादित करने के लिए विलंब मान भी होता है।

उदाहरण के लिए, यदि आप 5 सेकंड के लिए निष्पादन में देरी करना चाहते हैं, तो आपको निम्नलिखित कोड चाहिए:

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
service.schedule( new Runnable() { ... }, 5, TimeUnit.SECONDS);


यदि आप हर सेकंड निष्पादन को शेड्यूल करना चाहते हैं:

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
service.scheduleAtFixedRate( new Runnable() { ... }, 0, 1, TimeUnit.SECONDS);


और अंत में, यदि आप निष्पादन के बीच 1 सेकंड के अंतराल के साथ कोड निष्पादन असाइन करना चाहते हैं:

ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
service.scheduleWithFixedDelay( new Runnable() { ... }, 0, 1, TimeUnit.SECONDS);