कॉल करने योग्य में Thread.interrupted() को संभालने का सही तरीका?

Question

कॉल करने योग्य में Thread.interrupted() को संभालने का उचित तरीका क्या है? मुझे लगता है कि कॉल करने योग्य को एक इंटरप्टेड अपवाद फेंकना चाहिए; उदाहरण के लिए:

public class MyCallable implements Callable<Object> { 
    public Object call() { 
     Object result = null; 

     // Simulate long-running operation that calculates result 
     while (true) { 
      ... 
      if (Thread.interrupted()) { 
       throw new InterruptedException(); 
      } 
     } 

     result = ... // something produced by the long-running operation  

     return result; 
    } 
} 

क्या यह सही है, या इसे संभालने का एक और उचित तरीका है? धन्यवाद।

Answer 1

संपादित:

कुछ वापस करने के बाद आगे और पीछे, ऐसा लगता है जैसे आप अपने आईओ दिनचर्या बाधित करने के लिए सक्षम होना चाहते हैं। यह कुछ एनआईओ InterrutibleChannel कक्षाओं के लिए एक अच्छी नौकरी की तरह लगता है। उदाहरण के लिए, निम्नलिखित BufferedReader से पढ़ना बाधित है और InterruptedIOException फेंक देगा। more examples of the NIO code के लिए यहां देखें।

BufferedReader in = new BufferedReader(new InputStreamReader(
    Channels.newInputStream((new FileInputStream(
     new File(...))).getChannel()))); 

उसके बाद, आप future.cancel() जो अपने धागा बाधित हो जाएंगी कॉल और आईओ एक InterruptedIOException फेंकने के लिए हो सकता है। यदि ऐसा होता है, तो आप IOException को पकड़ सकते हैं और इसे call() विधि से बाहर निकलने दें।

---

आप Future कि call() विधि बाधित किया गया था तो मैं फेंकने लगता है कि InterruptedException ठीक है वापस करने के लिए पास करना चाहते हैं। एक और विकल्प केवल return null; या आपके call() विधि से कुछ अन्य मार्कर ऑब्जेक्ट होगा। अगर आम तौर पर धागा बाधित होता है तो मैं आमतौर पर ऐसा करता हूं।

एक बात याद रखना महत्वपूर्ण है कि अगर call() फेंकता InterruptedException, जब आप एक future.get() कर फेंक होगा एक ExecutionException और कारण कि अपवाद का एक InterruptedException होने जा रहा है है। भ्रमित न हों कि future.get()get(long timeout, TimeUnit unit) बार बाहर होने पर InterruptedException भी फेंक सकता है।

try { 
    result = future.get(); 
} catch (ExecutionException e) { 
    if (e.getCause() instanceof InterruptedException) { 
     // call() method was interrupted 
    } 
} catch (InterruptedException e) { 
    // get was interrupted 
} 

अगर, हालांकि, future.cancel(true) तो कहा जाता था future.get() एक CancellationException बजाय फेंक देते हैं।

Answer 2

यह वास्तव में इस बात पर निर्भर करता है कि आप get() पर थ्रेड का इंतजार कैसे करना चाहते हैं। आप नहीं प्रतीक्षा धागा एक अपवाद तो फेंक दिया है करना चाहते हैं यदि आप करते हैं कल्पना कीजिए

try{ 
    future.get(); 
}catch(ExecutionException ex){ 

}catch(InterruptedException em){ 

} 

throw new InterruptedException

नहीं चाहता किसी भी अपवाद तब होता है यदि आप इसे होने की उम्मीद करेंगे? आपके मामले में यह ExecutionException है। यदि आप ExecutionException नहीं चाहते हैं तो आपको इंटरप्टेड अपवाद को पुनर्स्थापित नहीं करना चाहिए।