जावा थ्रेड - अजीब Thread.interrupted() और future.cancel (सत्य) व्यवहार

Question

मैं अपने कार्यक्षेत्र द्वारा लौटाए गए फ़्यूचर्स ऑब्जेक्ट्स की एक सूची प्रबंधित करना चाहता हूं।
मैंने इस

List<Future<String>> list 

void process(ProcessThis processThis) {  
    for (...) { 
     Future<String> future = taskExecutor.submit(processThis); 
     list.add(future) 
    } 
} 


void removeFutures() { 
    for(Future future : list) { 
     assert future.cancel(true); 
} 

ProcessThis की तरह कुछ एक काम है कि Thread.interrupted के लिए लागू करता है प्रतिदेय < स्ट्रिंग> और चेक() की स्थिति

public String call() { 
     while (true) { 
      if (Thread.interrupted()) { 
       break; 
      } 
      doSomething(); 
     } 
    } 

अब समस्या यह है है कि केवल के एक सबसेट समवर्ती धागे 'सत्य' लौट रहे हैं जब Thread.interrupted() कहा जाता है।
हटाए गए फ्यूचर्स() में दिए गए हर क्षेत्र को हटाए गए भविष्य के लिए सत्य लौटाता है (मैंने जांच की है() और पूर्ण() है।
बाधित होने वाली थ्रेड की संख्या यादृच्छिक है। 15 से अधिक चलने वाले थ्रेड कभी-कभी 13 बाधित होते हैं, कभी-कभी 2 ...
मैं वास्तव में समझ नहीं पा रहा हूं कि समस्या कहां है। अगर मैं भविष्य को कॉल करता हूं। (सच) और यह सच हो जाता है ... और फिर मैं Thread.interrupted (इसे केवल एक बार कहा जाता है) की जांच करता हूं, मुझे उम्मीद है इस रूप में अच्छी तरह से सच लौटने के लिए।
मैं क्या याद आ रही है की कोई भी विचार?

मैं निर्माण जावा 1.6.0_02-B05 पर हूँ

Answer 1

कम से कम, आप interr बहाल करना चाहिए uption झंडा taskExecutor धागा रुकावट के बारे में पता करने के लिए:

public String call() { 
    while (true) { 
     if (Thread.interrupted()) { 
      Thread.currentThread().interrupt(); 
      break; 
     } 
     doSomething(); 
    } 
} 

Answer 2

एक संभावित समस्या है कि बीच में आता है अक्सर निगल लिया जाता है। तो कहीं doSomething() (या यहां तक ​​कि कक्षा लोडिंग में) में गहराई से, wait() कहकर एक बाधा पकड़ी जा सकती है और फिर 'लापरवाह' कोड से त्याग दिया जा सकता है। इंटरप्ट्स बुराई हैं, आईएमओ।

यह जांचने योग्य हो सकता है कि आप सभी कार्य वास्तव में रद्द होने के समय चल रहे हैं।

Answer 3

ध्यान रखें कि Thread.interrupted() वर्तमान बाधित स्थिति देता है और फिर इसे साफ़ करता है, इसलिए सभी भविष्य के आमंत्रण झूठे हो जाएंगे। आप जो चाहते हैं वह शायद Thread.currentThread().isInterrupted() है।

यह भी ध्यान रखें कि future.cancel(true) आमतौर पर केवल तभी वापस आ जाएगा जब कार्य पहले से ही पूरा हो चुका है या रद्द कर दिया गया है। यदि यह सच हो जाता है, तो यह गारंटी नहीं है कि कार्य वास्तव में रद्द कर दिया जाएगा।

doSomething() में क्या हो रहा है? यह संभव है कि रूकाइम अपवाद किसी भी बाधा के कारण कहीं से बच रहा है। क्या आपके पास UncaughtExceptionHandler सेट है? यदि नहीं, तो आपको ThreadFactory को Executor पर पास करने की आवश्यकता होगी जो अपवाद हैंडलर सेट करेगा और किसी भी चूक के अपवाद लॉग करेगा।