C++ Equivalente a Java's BlockingQueue

Question

Sono in procinto di eseguire il porting di un codice Java su C++ e una sezione specifica utilizza un BlockingQueue per passare messaggi da molti produttori a un singolo utente.

Se non si ha familiarità con cosa sia un Java BlockingQueue, è solo una coda con una capacità difficile, che espone metodi thread-safe da put() e take() dalla coda. put() blocca se la coda è piena e take() blocca se la coda è vuota. Inoltre, vengono fornite versioni sensibili a timeout di questi metodi.

I timeout sono rilevanti per il mio caso d'uso, quindi una raccomandazione che li fornisce è l'ideale. In caso contrario, posso indicizzarne qualcuno.

Ho cercato su Google e rapidamente ho sfogliato le librerie Boost e non trovo nulla di simile. Forse sono cieco qui ... ma qualcuno sa di una buona raccomandazione?

Grazie!

Answer 1

E non è fisso dimensioni e non supporta i timeout, ma qui è una semplice implementazione di una coda che avevo postato di recente utilizzando C++ 2011 costrutti:

#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; 
    } 
}; 

Dovrebbe essere banale per estendere e l'uso un'attesa a tempo per scoppiare. Il motivo principale per cui non l'ho fatto è che non sono soddisfatto delle scelte di interfaccia che ho pensato finora.