目標：主執行緒向其它執行緒發生訊息，其它執行緒收到訊息並處理。

虛擬碼目標：主執行緒將訊息加入listTemp連結串列，使用condition_variable的notify_one通知執行緒，其它執行緒將訊息處理，並將訊息加入到已處理listTemp2連結串列中。

 虛擬碼

#include <atomic>
#include <mutex>
#include <list>
#include <vector>
#include <thread>
#include <cassert>


int main()
{
	std::atomic<int> nNum = ATOMIC_VAR_INIT(0);

	std::mutex listMu;
	std::list<int> listTemp;

	std::mutex listMu2;
	std::list<int> listTemp2;

	std::condition_variable listCondition;

	std::vector<std::shared_ptr < std::thread >> listThread;

	int const nMax = 1000;

	for (int i = 0; i != 10; ++i)
	{
		auto pTh = std::make_shared <std::thread>([&listTemp,&listCondition,&listMu,&nNum,&listTemp2,&listMu2,nMax]
			()->void
		{
			
			while (true)
			{		
				int i = -1;

				{
					std::unique_lock<std::mutex> lc(listMu);
					while (listTemp.empty())
					{
						listCondition.wait(lc);

						{
							std::lock_guard<std::mutex> lc(listMu2);
							if (listTemp2.size() == nMax)
							{
								break;
							}
						}
					}

					{
						std::lock_guard<std::mutex> lc(listMu2);
						if (listTemp2.size() == nMax)
						{
							listCondition.notify_one();
							break;
						}
					}


					i = *listTemp.begin();
					listTemp.erase(listTemp.begin());					
				}
			



				//處理比較耗時的操作


				{
					std::lock_guard<std::mutex> lc(listMu2);
					listTemp2.push_back(i);
					if (listTemp2.size() == nMax)
					{
						listCondition.notify_one();
						break;
					}
				}

				std::this_thread::sleep_for(std::chrono::milliseconds(100));

				

			}
			
		});

		listThread.push_back(pTh);
	}	
		
	for (int i = 0; i != nMax; ++i)
	{
		{
			std::lock_guard<std::mutex> lc(listMu);
			listTemp.push_back(i);
			listCondition.notify_one();
		}		
		std::this_thread::sleep_for(std::chrono::milliseconds(15));
	}		

	//listCondition.notify_all();
	for (auto t : listThread)
	{
		t->join();
	}

	assert(nMax == listTemp2);

	std::cout << "結束" << std::endl;

	getchar();
    return 0;
}