/usr/share/doc/libglibmm-2.4-dev/examples/thread/thread.cc is in libglibmm-2.4-doc 2.56.0-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 | #include <condition_variable>
#include <iostream>
#include <memory>
#include <mutex>
#include <queue>
#include <thread>
#if defined(_MSC_VER) && (_MSC_VER < 1900)
/* For using noexcept on Visual Studio 2013 */
#include <glibmmconfig.h>
#endif
#include <glibmm/init.h>
#include <glibmm/random.h>
#include <glibmm/timer.h>
namespace
{
class MessageQueue
{
public:
MessageQueue();
~MessageQueue();
void producer();
void consumer();
private:
std::mutex mutex_;
std::condition_variable cond_push_;
std::condition_variable cond_pop_;
std::queue<int> queue_;
};
MessageQueue::MessageQueue()
{
}
MessageQueue::~MessageQueue()
{
}
void
MessageQueue::producer()
{
Glib::Rand rand(1234);
for (auto i = 0; i < 200; ++i)
{
{
std::unique_lock<std::mutex> lock(mutex_);
cond_pop_.wait(lock, [this]() -> bool { return queue_.size() < 64; });
queue_.push(i);
std::cout << '*';
std::cout.flush();
// We unlock before notifying, because that is what the documentation suggests:
// http://en.cppreference.com/w/cpp/thread/condition_variable
lock.unlock();
cond_push_.notify_one();
}
if (rand.get_bool())
continue;
Glib::usleep(rand.get_int_range(0, 100000));
}
}
void
MessageQueue::consumer()
{
Glib::Rand rand(4567);
for (;;)
{
{
std::unique_lock<std::mutex> lock(mutex_);
cond_push_.wait(lock, [this]() -> bool { return !queue_.empty(); });
const int i = queue_.front();
queue_.pop();
std::cout << "\x08 \x08";
std::cout.flush();
// We unlock before notifying, because that is what the documentation suggests:
// http://en.cppreference.com/w/cpp/thread/condition_variable
lock.unlock();
cond_pop_.notify_one();
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;
// TODO: Use std::make_unique() when we use C++14:
const auto producer =
std::unique_ptr<std::thread>(new std::thread(&MessageQueue::producer, &queue));
const auto consumer =
std::unique_ptr<std::thread>(new std::thread(&MessageQueue::consumer, &queue));
producer->join();
consumer->join();
std::cout << std::endl;
return 0;
}
|