श्रोता थ्रेड एलीव को कैसे रखें

Question

मेरे पास एक कक्षा है जो आने वाले संदेशों के लिए श्रोता है और हमेशा के लिए जिंदा रहना चाहिए (ताकि यह आने वाले संदेशों के लिए सुन सके) जब तक कि मैं इसके लिए कनेक्शन को स्पष्ट रूप से डिस्कनेक्ट नहीं करता। मैंने थ्रेड को सेटडैमन (झूठा) के रूप में घोषित कर दिया है लेकिन यह कॉलिंग विधियों की समाप्ति के साथ समाप्त हो जाता है।

कृपया मुझे बताएं कि उस धागे को जीवित रखने के लिए और कृपया कुछ प्रकाश डालने के लिए स्प्रिंग टास्क एक्स्सेलर को कैसे कार्यान्वित किया जाए, इस पर कुछ प्रकाश डालें।

अग्रिम धन्यवाद। यह एक श्रोता है जब कोई संदेश भेजता है तो उसे अधिसूचित किया जाता है ... तो मैं इसे कैसे चला सकता हूं?

श्रोता वर्ग

public class MyListnerImpl implements Listener { 
    private final connectionImpl con; 

    public MyListnerImpl(ConnectionImpl con) { 
    if (con.isAuthenticated() && con.isConnected()) { 
     if (logger.isInfoEnabled()) { 
      logger.info("Initializing XmppListner:"); 
     } 
     this.itsCon = con; 
     Thread t1 = new Thread(this); 
     t1.setDaemon(false); 
     t1.start(); 
    } 
    } 

    public final void listnerInterfaceMethod(final Chat chat, final Message message) { 
     System.out.println("Message" + message); 
    } 

    public final void run() { 
    itsCon.getChatManager().addChatListener(new ChatManagerListener() { 
     public void chatCreated(final Chat chat, final boolean createdLocally) { 
      if (!createdLocally) { 
       chat.addMessageListener(itsFbml); 
      } 
     } 
    }); 
    } 
} 

कॉलिंग वर्ग बस अपने वस्तु बनाता है और धागा श्रोताओं निर्माता द्वारा शुरू किया जाता है।

मैं इस थ्रेड को तब तक चलाना चाहता हूं जब तक कि मैं इसे बाधित नहीं करता।

उपयोग otherThread.join():

Answer 1

कुछ चीजें आप कर सकता है कि प्रारंभिक धागा हमेशा के लिए फांसी से बेहतर होगा रहे हैं। इससे वर्तमान धागे का कारण बन जाएगा जब तक कि अन्य थ्रेड निष्पादित नहीं हो जाता है। जैसा कि @ नंदा सुझाव देता है, थ्रेड के पूल समाप्त होने तक प्रतीक्षा करने के लिए ExcecutorService.shutdown() का उपयोग करें। otherThread.setDaemon(false) का उपयोग करें और बस अपना प्रारंभिक थ्रेड निकालें। यह आपके नए धागे को उपयोगकर्ता धागे के रूप में सेट करेगा। जावा तब तक बंद नहीं होगा जब तक कि केवल थ्रेड चलने वाले डिमन थ्रेड न हों। जब तक किसी को notify() कहता है, या हमेशा के

synchronized(this) { 
    while (true) { 
     this.wait(); 
    } 
} 

यह वर्तमान वर्ग के मॉनिटर पर वर्तमान धागा इंतजार कर देगा।

से How do you hang a thread in Java in one line?

Answer 2

की नकल की (या एक त्रुटि/अपवाद फेंक) आप इसे जिंदा रखने के लिए, एक पाश का उपयोग करना चाहते हैं, तो वापस जाने के लिए और किसी भी त्रुटि/अपवाद नहीं पकड़ एक धागा run() रिटर्न जब तक जिंदा कहते हैं।

Answer 3

यह मैं कैसे समस्याओं को हल किया है कि समय, तो इस मामले बहु सूत्रण का नहीं था, बस एक ही धागा जो हमेशा के लिए चलाने के लिए आवश्यक, तो

public final void run() { 
while(true) 
{ 
//Run Method Logic... 
} 
} 

सम्मिलित किया गया था और से यह instantiated है एक वसंत बीन। मैं इस एकल थ्रेडेड परिदृश्य जैसे awaitTermination() के लिए और अधिक फैंसी चीजें देख रहा था; या कुछ इस तरह का।