सी ++ जावा के अवरुद्ध करने के लिए समतुल्य

Question

मैं कुछ जावा कोड को सी ++ पर पोर्ट करने की प्रक्रिया में हूं, और एक विशेष अनुभाग कई उत्पादकों से संदेशों को एक उपभोक्ता को पास करने के लिए ब्लॉकिंगक्यूयू का उपयोग करता है।

यदि आप जावा अवरोधक्यूयू के बारे में परिचित नहीं हैं, तो यह केवल एक कतार है जिसमें हार्ड क्षमता है, जो कतार से() और ले() ले जाने के लिए थ्रेड सुरक्षित विधियों का खुलासा करता है। कतार भरने पर ब्लॉक() ब्लॉक करें, और कतार खाली होने पर ब्लॉक() ब्लॉक करें। साथ ही, इन विधियों के टाइमआउट-संवेदनशील संस्करणों की आपूर्ति की जाती है।

टाइमआउट मेरे उपयोग-मामले के लिए प्रासंगिक हैं, इसलिए एक सिफारिश जो उन्हें आपूर्ति करती है आदर्श है। यदि नहीं, तो मैं कुछ खुद को कोड कर सकता हूं।

मैंने बूस्ट पुस्तकालयों को चारों ओर घुमाया और जल्दी से ब्राउज़ किया और मुझे ऐसा कुछ नहीं मिला। शायद मैं यहाँ अंधा हूं ... लेकिन क्या किसी को भी अच्छी सिफारिश के बारे में पता है?

धन्यवाद!

#include <mutex> 
#include <condition_variable> 
#include <deque> 

template <typename T> 
class queue 
{ 
private: 
    std::mutex    d_mutex; 
    std::condition_variable d_condition; 
    std::deque<T>   d_queue; 
public: 
    void push(T const& value) { 
     { 
      std::unique_lock<std::mutex> lock(this->d_mutex); 
      d_queue.push_front(value); 
     } 
     this->d_condition.notify_one(); 
    } 
    T pop() { 
     std::unique_lock<std::mutex> lock(this->d_mutex); 
     this->d_condition.wait(lock, [=]{ return !this->d_queue.empty(); }); 
     T rc(std::move(this->d_queue.back())); 
     this->d_queue.pop_back(); 
     return rc; 
    } 
}; 

यह विस्तार करने के लिए तुच्छ होना चाहिए और उपयोग:

Answer 1

यह आकार तय नहीं है और यह समय समाप्ति का समर्थन नहीं करता, लेकिन यहाँ एक कतार का एक सरल कार्यान्वयन मैं हाल ही में पोस्ट किया था सी ++ 2011 निर्माणों उपयोग कर रहा है पॉपिंग के लिए एक समय प्रतीक्षा। मैंने ऐसा नहीं किया है कि मुख्य कारण यह है कि मैं अब तक के इंटरफ़ेस विकल्पों से खुश नहीं हूं।