日本黄色一级经典视频|伊人久久精品视频|亚洲黄色色周成人视频九九九|av免费网址黄色小短片|黄色Av无码亚洲成年人|亚洲1区2区3区无码|真人黄片免费观看|无码一级小说欧美日免费三级|日韩中文字幕91在线看|精品久久久无码中文字幕边打电话

21IC電子網(wǎng) | 芯聞號(hào)

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

充電吧
2018-10-26 09:04
關(guān)鍵字: c++ 構(gòu)造函數(shù)
收藏

? ? ? ?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)在這個(gè)io_service上的deadline_timer。

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

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

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種用法是等價(jià)的:

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));

前者是絕對(duì)時(shí)間,后者是相對(duì)時(shí)間。

二.同步

一個(gè)deadline_timer只維護(hù)一個(gè)超時(shí)時(shí)間,一個(gè)deadline_timer不同時(shí)維持多個(gè)定時(shí)器。

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

這是個(gè)同步等待函數(shù),例如:

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

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

三.異步

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

注意這個(gè)error很重要,表明這個(gè)handler是因?yàn)槌瑫r(shí)被執(zhí)行還是因?yàn)楸籧ancel。
符合2種情況之一,handler被執(zhí)行:超時(shí)或者被cancel。
這同時(shí)隱含的說明了除非io.stop被調(diào)用,否則handler一定會(huì)被執(zhí)行。即便是被cancel。
被cancel有多種方法,直接調(diào)用cancel或者調(diào)用expires_at,expires_from_now重新設(shè)置超時(shí)時(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!


相關(guān)推薦