C++

queue avec variables conditionnelles (boost)

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : queue avec variables conditionnelles (boost)

in_your_phion

bonjour,

j'aimerais savoir si mon implémentation d'une queue avec deux threads (un consommateur et un producteur) vous parait correcte ?

merci par avance !

ps : j'ai fait avec boost.

Code :

#include <queue>
using namespace std;
#include "boost/signals2/mutex.hpp"
#include "boost/thread/thread.hpp"
#include "boost/thread/condition.hpp"
#include "boost/thread/locks.hpp"
class MyQueue
{
public:
unsigned pop();
void push( const unsigned elem );
bool isEmpty() const;
private:
std::list<unsigned> _queue;
mutable boost::signals2::mutex _mtx;
boost::condition _cond;
};
void MyQueue::push( const unsigned elem )
{
boost::lock_guard<boost::signals2::mutex> guard( _mtx );
_queue.push_back( elem );
_cond.notify_one();
//unlocked on stack unwiding
}
unsigned MyQueue::pop()
{
boost::lock_guard<boost::signals2::mutex> guard( _mtx );
while ( _queue.empty() )
_cond.wait( _mtx );
unsigned element = _queue.front();
_queue.pop_front();
return element;
}
bool MyQueue::isEmpty() const
{
boost::lock_guard<boost::signals2::mutex> guard( _mtx );
return _queue.empty();
}
class Producer : public boost::thread
{
public:
Producer( MyQueue & q ) : _q( & q )
{
boost::thread( boost::BOOST_BIND(&Producer::run, this) );
}
void run()
{
for ( int i = 0 ; ; ++i )
{
_q->push(i);
yield();
//boost::this_thread::sleep( boost::posix_time::milliseconds(1));
}
cout << "producer thread stopped." << endl;
}
private:
MyQueue * _q;
};
class Consumer : public boost::thread
{
public:
Consumer( MyQueue & q ) : _q( & q )
{
boost::thread( boost::BOOST_BIND(&Consumer::run, this) );
}
void run()
{
while ( ! interruption_requested() )
{
int elem = _q->pop();
}
}
private:
MyQueue * _q;
};
int main(int argc, char *argv[])
{
MyQueue q;
Consumer consumer( q );
Producer producer( q );
consumer.join();
producer.join();
cin.get();
return 0;
}

Publicité

theshockwave

I work at a firm named Koslow

Techniquement, tu peux implémenter une queue thread safe sans mutex (si ta plateforme te garantit des écriture atomiques pour tes pointeurs, c'est assez simple)

edit : typo

Message édité par theshockwave le 19-02-2013 à 14:47:19

---------------
last.fm

FORUM HardWare.fr

Programmation

C++

queue avec variables conditionnelles (boost)

Sujets relatifs
questions d'entretien sur Boost ?	Comment inscrire des variables dans un fichier PHP ? (fwrite)
[VBS]Récupération de variables dans un fichier INI	Récupérer des variables d'un fichier INI
JS fonctions et variables redéfinies	(Cplex & C++) Comment résupérer les variables de base ?
Boost dijkstra : recuperer l'intégralité du chemin	Incrémenter les noms de variables (var1, var2, var3, ...)
[PHP] Conseil stockage variables	Bien sécuriser les variables GET
Plus de sujets relatifs à : queue avec variables conditionnelles (boost)

Page générée en 0.102 secondes