113 lines
1.7 KiB
C++
113 lines
1.7 KiB
C++
#include <iostream>
|
|
#include <queue>
|
|
#include <glibmm/threads.h>
|
|
#include <glibmm/random.h>
|
|
#include <glibmm/timer.h>
|
|
#include <glibmm/init.h>
|
|
|
|
namespace
|
|
{
|
|
|
|
class MessageQueue : public sigc::trackable
|
|
{
|
|
public:
|
|
MessageQueue();
|
|
~MessageQueue();
|
|
|
|
void producer();
|
|
void consumer();
|
|
|
|
private:
|
|
Glib::Threads::Mutex mutex_;
|
|
Glib::Threads::Cond cond_push_;
|
|
Glib::Threads::Cond cond_pop_;
|
|
std::queue<int> queue_;
|
|
};
|
|
|
|
|
|
MessageQueue::MessageQueue()
|
|
{}
|
|
|
|
MessageQueue::~MessageQueue()
|
|
{}
|
|
|
|
void MessageQueue::producer()
|
|
{
|
|
Glib::Rand rand (1234);
|
|
|
|
for(int i = 0; i < 200; ++i)
|
|
{
|
|
{
|
|
Glib::Threads::Mutex::Lock lock (mutex_);
|
|
|
|
while(queue_.size() >= 64)
|
|
cond_pop_.wait(mutex_);
|
|
|
|
queue_.push(i);
|
|
std::cout << '*';
|
|
std::cout.flush();
|
|
|
|
cond_push_.signal();
|
|
}
|
|
|
|
if(rand.get_bool())
|
|
continue;
|
|
|
|
Glib::usleep(rand.get_int_range(0, 100000));
|
|
}
|
|
}
|
|
|
|
void MessageQueue::consumer()
|
|
{
|
|
Glib::Rand rand (4567);
|
|
|
|
for(;;)
|
|
{
|
|
{
|
|
Glib::Threads::Mutex::Lock lock (mutex_);
|
|
|
|
while(queue_.empty())
|
|
cond_push_.wait(mutex_);
|
|
|
|
const int i = queue_.front();
|
|
queue_.pop();
|
|
std::cout << "\x08 \x08";
|
|
std::cout.flush();
|
|
|
|
cond_pop_.signal();
|
|
|
|
if(i >= 199)
|
|
break;
|
|
}
|
|
|
|
if(rand.get_bool())
|
|
continue;
|
|
|
|
Glib::usleep(rand.get_int_range(10000, 200000));
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
|
|
int main(int, char**)
|
|
{
|
|
Glib::init();
|
|
|
|
MessageQueue queue;
|
|
|
|
Glib::Threads::Thread *const producer = Glib::Threads::Thread::create(
|
|
sigc::mem_fun(queue, &MessageQueue::producer));
|
|
|
|
Glib::Threads::Thread *const consumer = Glib::Threads::Thread::create(
|
|
sigc::mem_fun(queue, &MessageQueue::consumer));
|
|
|
|
producer->join();
|
|
consumer->join();
|
|
|
|
std::cout << std::endl;
|
|
|
|
return 0;
|
|
}
|
|
|