बूस्ट थ्रेड -

Question

को अवरुद्ध करने के लिए कैसे करें मेरे पास कार्य को अवरुद्ध कर दिया गया है जो find_the_question() फ़ंक्शन द्वारा किया जाएगा। हालांकि, मैं नहीं चाहता कि इस फ़ंक्शन को निष्पादित करने वाले थ्रेड को 10 सेकंड से अधिक समय लगे। तो यदि इसमें 10 सेकंड से अधिक समय लगता है, तो मैं सभी संसाधनों की सफाई के साथ उस थ्रेड को बंद करना चाहता हूं।

मैंने इसके लिए एक कोड लिखने की कोशिश की, लेकिन किसी भी तरह से अगर मैं 10 सेकंड से अधिक समय लेता है तो मैं find_the_question() फ़ंक्शन में कोई बाधा नहीं पा रहा हूं। क्या आप कृपया मुझे बता सकते हैं कि मैं क्या गलत कर रहा हूं?

void find_the_question(std::string value) 
{ 
    //allocate x resources 
    try{ 
     //do some process on resources 
      sleep(14); 
     //clean resources 
    } 
    catch(boost::thread_interrupted const&) 
    { 
     //clean resources 
     std::cout << "Worker thread interrupted" << std::endl; 
    } 
} 

int main() 
{ 
     boost::posix_time::time_duration timeout = boost::posix_time::milliseconds(10000); 
     std::cout << "In main" << std::endl; 
     boost::thread t1(find_the_question, "Can you block me"); 

     t1.interrupt(); 
     if (t1.timed_join(timeout)) 
     { 
      //finished 
      std::cout << "Worker thread finished" << std::endl; 
     } 
     else 
     { 
      //Not finished; 
      std::cout << "Worker thread not finished" << std::endl; 
     } 

     std::cout << "In main end" << std::endl; 
} 

आउटपुट: t1 पूरा करने के लिए 10 सेकंड से अधिक लेता है हैं, मैं कंसोल आउटपुट निम्नलिखित हो रही है।

std::cout << "In main" << std::endl; 
std::cout << "Worker thread not finished" << std::endl; 
std::cout << "In main end" << std::endl; 

जबकि, मैं उत्पादन

std::cout << "In main" << std::endl; 
std::cout << "Worker thread interrupted" << std::endl; 
std::cout << "Worker thread not finished" << std::endl; 
std::cout << "In main end" << std::endl; 

आप मुझे बता सकते हैं क्या मैं गलत कर रहा हूँ निम्नलिखित की उम्मीद कर रहा हूँ।

अग्रिम

Answer 1

बढ़ावा :: धागा :: बाधा() का उपयोग कर के लिए धन्यवाद, आप इसे काम करने के लिए बढ़ावा :: धागा :: नींद() का उपयोग करने के लिए है।

एक दौड़ धागा बाधा() इसी बढ़ावा :: धागा वस्तु के सदस्य समारोह लागू द्वारा बाधित किया जा सकता है। जब अवरोधित थ्रेड अंक (या यदि इसे वर्तमान में अवरुद्ध करते समय अवरुद्ध किया जाता है) में से एक को निष्पादित करता है तो बाधा सक्षम के साथ, तो बूस्ट :: thread_interrupted अपवाद बाधित थ्रेड में फेंक दिया जाएगा। यदि पकड़ा नहीं गया है, तो यह को बाधित करने के लिए बाधित थ्रेड के निष्पादन का कारण बन जाएगा। किसी भी अन्य अपवाद के साथ के रूप में, ढेर खुला हुआ हो जाएगा, और स्वत: भंडारण की अवधि का वस्तुओं के लिए विनाशकर्ता

निष्पादित किया जाएगा

पूर्वनिर्धारित रुकावट अंक:

निम्नलिखित कार्य, बाधा अंक हैं जो होगा बढ़ावा फेंक :: thread_interrupted अगर रुकावट वर्तमान थ्रेड के लिए सक्षम है, और किसी रुकावट के वर्तमान थ्रेड के लिए अनुरोध किया गया है:

boost::thread::join() 
boost::thread::timed_join() 
boost::condition_variable::wait() 
boost::condition_variable::timed_wait() 
boost::condition_variable_any::wait() 
boost::condition_variable_any::timed_wait() 
boost::thread::sleep() 
boost::this_thread::sleep() 
boost::this_thread::interruption_point()