Boost.Asio C++ 網(wǎng)絡(luò)編程：deadline_timer使用說明

? ? ? ?deadline_timer和socket一樣，都用io_service作為構(gòu)造函數(shù)的參數(shù)。也即，在其上進(jìn)行異步操作，都將導(dǎo)致和io_service所包含的iocp相關(guān)聯(lián)。這同樣意味著在析構(gòu) io_service之前，必須析構(gòu)關(guān)聯(lián)在這個io_service上的deadline_timer。

一.構(gòu)造函數(shù)

在構(gòu)造deadline_timer時指定時間。

basic_deadline_timer(??
????boost::asio::io_service?&?io_service);??
??
basic_deadline_timer(??
????boost::asio::io_service?&?io_service,??
????const?time_type?&?expiry_time);??
??
basic_deadline_timer(??
????boost::asio::io_service?&?io_service,??
????const?duration_type?&?expiry_time);

注意后兩種的區(qū)別。以下2種用法是等價的：

boost::asio::deadline_timer?t(io,?boost::posix_time::microsec_clock::universal_time()+boost::posix_time::seconds(5));??
boost::asio::deadline_timer?t(io,?boost::posix_time::seconds(5));

前者是絕對時間，后者是相對時間。

二.同步

一個deadline_timer只維護(hù)一個超時時間，一個deadline_timer不同時維持多個定時器。

void?wait();??
void?wait(boost::system::error_code&?ec);

這是個同步等待函數(shù)，例如：

boost::asio::io_service?io;??
boost::asio::deadline_timer?t(io,?boost::posix_time::seconds(5));??
t.wait();

由于不涉及到異步，該函數(shù)和io_service沒什么關(guān)系。這個函數(shù)在windows下的實現(xiàn)就只是簡單的sleep。因此也就不存在cancel之說。

三.異步

templateBOOST_ASIO_INITFN_RESULT_TYPE(WaitHandler,
?????void?(boost::system::error_code))
?async_wait(BOOST_ASIO_MOVE_ARG(WaitHandler)?handler)

注意這個error很重要，表明這個handler是因為超時被執(zhí)行還是因為被cancel。
符合2種情況之一，handler被執(zhí)行：超時或者被cancel。
這同時隱含的說明了除非io.stop被調(diào)用，否則handler一定會被執(zhí)行。即便是被cancel。
被cancel有多種方法，直接調(diào)用cancel或者調(diào)用expires_at，expires_from_now重新設(shè)置超時時間。

四.例子

#ifdef?WIN32
#define?_WIN32_WINNT?0x0501
#include#endif

#include#include#include#include#includeusing?namespace?boost::asio;

void?print(const?boost::system::error_code&)
{
	std::cout?<<?"Hello,?world!"?<<?std::endl;
}

void?handle_wait(const?boost::system::error_code&?error,
	boost::asio::deadline_timer&?t,
	int&?count)
{
	if?(!error)
	{
		std::cout?<<?count?<<?std::endl;
		if?(count++?<?5)
		{
			t.expires_from_now(boost::posix_time::seconds(3));
			t.async_wait(boost::bind(handle_wait,
				boost::asio::placeholders::error,
				boost::ref(t),
				boost::ref(count)));
			if?(count?==?3)
			{
				t.cancel();
			}

		}
	}
}

//?同步方法??
void?test_timer_syn()
{
	boost::asio::io_service?ios;
	boost::asio::deadline_timer?t(ios,?boost::posix_time::seconds(3));
	t.wait();
	std::cout?<<?"syn?deadline_timer!"?<<?std::endl;
}

//?異步方法:3秒后執(zhí)行print方法
void?test_timer_asyn()
{
	boost::asio::io_service?io;
	boost::asio::deadline_timer?t(io,?boost::posix_time::seconds(3));
	t.async_wait(print);
	std::cout?<<?"asyn?deadline_timer!"?<<?std::endl;
	io.run();
}

//?異步循環(huán)執(zhí)行方法
void?test_timer_asyn_loop()
{
	boost::asio::io_service?io;
	boost::asio::deadline_timer?t(io);
	size_t?a?=?t.expires_from_now(boost::posix_time::seconds(1));

	int?count?=?1;
	t.async_wait(boost::bind(handle_wait,
		boost::asio::placeholders::error,
		boost::ref(t),
		boost::ref(count)));
	io.run();
}

int?main(int?argc,?char*?argv[])?{
//	test_timer_syn();
	test_timer_asyn();
//	test_timer_asyn_loop();
	system("pause");
}

異步方法執(zhí)行的結(jié)果如下所示：

先打印出asyn deadline_timer!，三秒后打印Hello,world!