【Boost】boostライブラリasio詳細1-strandとio_サービスの違い

namespace
{
	// strand ,  ,  post dispatch ,  . 
	// io_service 
	boost::asio::io_service m_service;
	boost::asio::strand m_strand(m_service);
	boost::mutex m_mutex;

	void print(int id)
	{
		// boost::mutex::scoped_lock lock(m_mutex);
		static int count = 0;
		PRINT_DEBUG("id: " << boost::lexical_cast<std::string>(id));
		PRINT_DEBUG("count: " << boost::lexical_cast<std::string>(++count));
	}
	
	void ioRun1()
	{
		while(true)
		{
			m_service.run();
		}
	}

	void ioRun2()
	{
		while(true)
		{
			m_service.run();
		}
	}

	void strand_print1()
	{
		// PRINT_DEBUG("Enter print1");
		m_strand.dispatch(boost::bind(print, 1));
		// PRINT_DEBUG("Exit print1");
	}

	void strand_print2()
	{
		// PRINT_DEBUG("Enter print2");
		m_strand.post(boost::bind(print, 2));
		// PRINT_DEBUG("Exit print2");
	}

	void strand_print3()
	{
		// PRINT_DEBUG("Enter print3");              
		m_strand.post(boost::bind(print, 3));
		// PRINT_DEBUG("Exit print3");
	}

	void strand_print4()
	{
		// PRINT_DEBUG("Enter print4");
		m_strand.post(boost::bind(print, 4));
		// PRINT_DEBUG("Exit print4");
	}

	//  m_strand m_service ，
	void service_print1()
	{
		// PRINT_DEBUG("Enter print1");
		m_service.dispatch(boost::bind(print, 1));
		// PRINT_DEBUG("Exit print1");
	}

	void service_print2()
	{
		// PRINT_DEBUG("Enter print2");
		m_service.post(boost::bind(print, 2));
		// PRINT_DEBUG("Exit print2");
	}

	void service_print3()
	{
		// PRINT_DEBUG("Enter print3");              
		m_service.post(boost::bind(print, 3));
		// PRINT_DEBUG("Exit print3");
	}

	void service_print4()
	{
		// PRINT_DEBUG("Enter print4");
		m_service.post(boost::bind(print, 4));
		// PRINT_DEBUG("Exit print4");
	}
}

void test_strand()
{
	boost::thread ios1(ioRun1);
	boost::thread ios2(ioRun2);
	
	boost::thread t1(strand_print1);
	boost::thread t2(strand_print2);
	boost::thread t3(strand_print3);
	boost::thread t4(strand_print4);

	t1.join();
	t2.join();
	t3.join();
	t4.join();

	m_server.run();
}

void test_service()
{
	boost::thread ios1(ioRun1);
	boost::thread ios2(ioRun2);

	boost::thread t1(service_print1);
	boost::thread t2(service_print2);
	boost::thread t3(service_print3);
	boost::thread t4(service_print4);
	
	t1.join();
	t2.join();
	t3.join();
	t4.join();
	
	m_service.run();
}

test_strandの実行結果:

2013-01-05 17:25:34 626 [8228] DEBUG - id: 4
2013-01-05 17:25:34 631 [8228] DEBUG - count: 1
2013-01-05 17:25:34 634 [5692] DEBUG - id: 1
2013-01-05 17:25:34 637 [5692] DEBUG - count: 2
2013-01-05 17:25:34 640 [5692] DEBUG - id: 2
2013-01-05 17:25:34 642 [5692] DEBUG - count: 3
2013-01-05 17:25:34 646 [5692] DEBUG - id: 3
2013-01-05 17:25:34 649 [5692] DEBUG - count: 4

test_ioseriviceの実行結果:

2013-01-05 17:26:28 071 [3236] DEBUG - id: 1
2013-01-05 17:26:28 071 [5768] DEBUG - id: 2
2013-01-05 17:26:28 071 [5108] DEBUG - id: 3
2013-01-05 17:26:28 076 [3236] DEBUG - count: 1
2013-01-05 17:26:28 079 [5768] DEBUG - count: 2
2013-01-05 17:26:28 083 [5108] DEBUG - count: 3
2013-01-05 17:26:28 087 [3236] DEBUG - id: 4
2013-01-05 17:26:28 099 [3236] DEBUG - count: 4

結果からtest_strandでprintの2つの印刷関数がペアで実行され、test_ioserviceの2つの印刷関数はスレッドが安全ではない.
test_を保証するならioservice同期は、mutexを加えてコードに注釈された文です.
注意ログのスレッド番号から分かるように、print()を本当に実行するのはメインスレッド、ios 1、ios 2であり、t 1、t 2、t 3、t 4スレッドはioserviceのキューにタスクを加えるだけである.