/*
 * 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;
}