当前位置:首页 > 芯闻号 > 充电吧
[导读]       deadline_timer和socket一样,都用io_service作为构造函数的参数。也即,在其上进行异步操作,都将导致和io_service所包含的iocp相关联。这同样意味着在

       deadline_timer和socket一样,都用io_service作为构造函数的参数。也即,在其上进行异步操作,都将导致和io_service所包含的iocp相关联。这同样意味着在析构 io_service之前,必须析构关联在这个io_service上的deadline_timer。

一.构造函数

在构造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);

注意后两种的区别。以下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只维护一个超时时间,一个deadline_timer不同时维持多个定时器。

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

这是个同步等待函数,例如:

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

由于不涉及到异步,该函数和io_service没什么关系。这个函数在windows下的实现就只是简单的sleep。因此也就不存在cancel之说。

三.异步

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

注意这个error很重要,表明这个handler是因为超时被执行还是因为被cancel。
符合2种情况之一,handler被执行:超时或者被cancel。
这同时隐含的说明了除非io.stop被调用,否则handler一定会被执行。即便是被cancel。
被cancel有多种方法,直接调用cancel或者调用expires_at,expires_from_now重新设置超时时间。

四.例子

#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秒后执行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();
}

// 异步循环执行方法
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");
}

异步方法执行的结果如下所示:


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


本站声明: 本文章由作者或相关机构授权发布,目的在于传递更多信息,并不代表本站赞同其观点,本站亦不保证或承诺内容真实性等。需要转载请联系该专栏作者,如若文章内容侵犯您的权益,请及时联系本站删除( 邮箱:macysun@21ic.com )。
换一批
延伸阅读
关闭