[C++11] Example of producer/consumer threads sharing data thanks to a queue protected by a mutex

producer_consumer_threads.cpp

#include <iostream>
#include <mutex>
#include <queue>
#include <sstream>
#include <thread>

int main(int, char*[]) {

	std::queue<std::string> queue;
	std::mutex mutex;

	// Producer
	std::thread producer([&]() {

		auto produce = [&](const char* message) {
			std::stringstream stream;
			stream << message;
			auto element = stream.str();

			std::cout << "Pushing " << message << std::endl;
			mutex.lock();
			queue.push(element);
			mutex.unlock();
		};

		produce("hello, world");
		produce("bye bye!");
		produce(":)");
	});

	// Consumer
	std::thread consumer([&]() {
		while (true) {
			if(not queue.empty()) {
				mutex.lock();
				auto message = queue.front();
				queue.pop();
				mutex.unlock();
				std::cout << "Received = " << message << std::endl;
			}
		}
	});

	// Main
	producer.join();
	consumer.join();
}