वसंत रद्द करें @ एसिंक कार्य

Question

मैं अपने भविष्य के @Async एनोटेशन के साथ चिह्नित एक विधि को रद्द करने में सक्षम होना चाहता हूं।

मेरे पास @Async एनोटेशन के साथ चिह्नित एक स्प्रिंग विधि है। यह विधि कुछ गणना करता है, और अंततः परिणाम देता है। मैंने देखा है कि सभी उदाहरण इस भविष्य को वापस करने के लिए AsyncResult कक्षा का उपयोग करने की सलाह देते हैं।

@Async 
public Future<String> run() { 
    // ... Computation. Minutes pass ... 
    return new AsyncResult<String>("Result"); 
} 

मैं निम्नलिखित तरीके से, किसी अन्य घटक से निम्न विधि को कॉल करता हूं। उदाहरण के प्रयोजनों के लिए, मैं तुरंत इस धागे को रद्द करना चाहता हूं:

Future<String> future = component.run(); 
future.cancel(true); 

इस मामले में, धागा कभी रद्द नहीं किया जाएगा। ऐसा इसलिए है क्योंकि, AsyncResult के लिए वसंत कार्यान्वयन को यहां देखें: https://github.com/spring-projects/spring-framework/blob/master/spring-context/src/main/java/org/springframework/scheduling/annotation/AsyncResult.java#L71, यह विधि वास्तव में एक ही चीज़ नहीं करती है। यह बस झूठा लौटाता है, कि धागा रद्द नहीं किया जा सका। यह मेरी समस्या है। मैं @Async विधि द्वारा बनाए गए थ्रेड को कैसे रद्द कर सकता हूं? मुझे वसंत द्वारा बनाए गए आंतरिक धागे तक कोई पहुंच नहीं है - इसलिए मेरे पास इसका कोई मतलब नहीं है जिसके साथ इसे रद्द करना है, क्या मैं?

Answer 1

असल में, वसंत @Async अपने स्वयं के पृष्ठभूमि थ्रेड पूल का उपयोग करता है। और जब तक निष्पादक सेवा के भविष्य या शटडाउन Now() की रद्द() विधि का संबंध है, executor.shutdownNow() or future.cancel(true) पर कॉल करना तुरंत चल रहे थ्रेड को रोकें। इन तरीकों का क्या संबंध है संबंधित संबंधों पर बस .interrupt() पर कॉल करें। और interrupts में कोई गारंटी नहीं तत्काल प्रभाव है। यह झंडा जारी करता है इसलिए जब भी सोने या प्रतीक्षा राज्य में, धागा बंद कर दिया जाएगा।

ध्यान दें, यदि आपके कार्य बाधाओं को अनदेखा करते हैं, तो executor.shutdownNow() and future.cancel(true)executor.shutdown() and future.cancel(false) जैसा ही व्यवहार करेगा।

यदि आपको धीमी या अवरुद्ध संचालन को रोकने के लिए एक तरीका चाहिए। यदि आपके पास एक लंबा/अंतहीन पाश है, तो आप केवल Thread.currentThread().isInterrupted() पर एक शर्त जोड़ सकते हैं और यदि यह सत्य है (ऑपरेशन समाप्त करें) जारी रखें।