Ticket #9221: multithread_producer.cpp

/*
 * multithread_producer.cpp
 *
 *  Created on: 10 окт. 2013 г.
 *      Author: aleksander
 */

#include <boost/bind.hpp>
#include <boost/thread.hpp>
#include <boost/interprocess/ipc/message_queue.hpp>
#include <vector>
boost::mutex mutex;

void send(boost::interprocess::message_queue* q) {
//      boost::mutex::scoped_lock lock(mutex);
        char buff;
        for (int i = 0; i < 10000; i++) {
                q->send(&buff, 1, 0);
        }
        std::cout<<"writer thread complete"<<std::endl;
}

void receive(boost::interprocess::message_queue* q) {
        char buff;
        size_t size;
        unsigned int priority;
        do {
                q->receive(&buff, 1, size, priority);
        } while (size > 0);
        std::cout<<"reader thread complete"<<std::endl;
}

const int THREAD_COUNT = 2;
int main(int argc, char **argv) {

        try {
                char queue_name[] = "queue_test";
                boost::interprocess::message_queue::remove(queue_name);
                boost::interprocess::message_queue mq(boost::interprocess::open_or_create, queue_name, 100, 1);

                std::vector<boost::thread*> threads;

                for (int i = 0; i < THREAD_COUNT; i++) {
                        threads.push_back(new boost::thread(boost::bind(send, &mq)));
                }
                threads.push_back(new boost::thread(boost::bind(receive, &mq)));

                for (int i = 0; i < THREAD_COUNT; i++) {
                        threads[i]->join();
                }

                char buff;

                mq.send(&buff, 0, 0);

                threads[THREAD_COUNT]->join();
                std::cout << "complete" << std::endl;
        } catch (std::exception &e) {
                std::cout << "error " << e.what() << std::endl;
        }
        return 0;
}