在这几个函数里.其实都是调用了do_one这个函数,而这个函数的作用就是从获取完成端口状态,所有定时器以及网络事件都是通过do_one来调度的.do_one的函数原型:

size_t do_one(bool block, boost::system::error_code& ec);

它的第一个参数说明了是否阻塞,在do_one代码中:

BOOL ok = ::GetQueuedCompletionStatus(iocp_.handle, &bytes_transferred,
 &completion_key, &overlapped, block ? timeout : 0);

可以看到如果为false,将等待时间为0(即不阻塞).

而run,run_one,及poll,poll_one的实现也相当简单,如下:

// Run the event loop until stopped or no more work. 
size_t run(boost::system::error_code& ec) 
{ 
if (::InterlockedExchangeAdd(&outstanding_work_, 0) == 0) 
{ 
stop(); 
ec = boost::system::error_code(); 
return 0; 
} 
 
call_stack<win_iocp_io_service>::context ctx(this); 
 
size_t n = 0; 
while (do_one(true, ec)) 
if (n != (std::numeric_limits<size_t>::max)()) 
++n; 
return n; 
} 
 
// Run until stopped or one operation is performed. 
size_t run_one(boost::system::error_code& ec) 
{ 
if (::InterlockedExchangeAdd(&outstanding_work_, 0) == 0) 
{ 
stop(); 
ec = boost::system::error_code(); 
return 0; 
} 
 
call_stack<win_iocp_io_service>::context ctx(this); 
 
return do_one(true, ec); 
} 
 
// Poll for operations without blocking. 
size_t poll(boost::system::error_code& ec) 
{ 
if (::InterlockedExchangeAdd(&outstanding_work_, 0) == 0) 
{ 
stop(); 
ec = boost::system::error_code(); 
return 0; 
} 
 
call_stack<win_iocp_io_service>::context ctx(this); 
 
size_t n = 0; 
while (do_one(false, ec)) 
if (n != (std::numeric_limits<size_t>::max)()) 
++n; 
return n; 
} 
 
// Poll for one operation without blocking. 
size_t poll_one(boost::system::error_code& ec) 
{ 
if (::InterlockedExchangeAdd(&outstanding_work_, 0) == 0) 
{ 
stop(); 
ec = boost::system::error_code(); 
return 0; 
} 
 
call_stack<win_iocp_io_service>::context ctx(this); 
 
return do_one(false, ec); 
} 

可以看到,run其实就是一直循环执行do_one,并且是以阻塞方式进行的(参数为true),而run_one同样是以阻塞方式进行的,但只执行一次do_one.poll和run几乎完全相同,只是它是以非阻塞方式执行do_one(参数为false).poll_one是以非阻塞方式执行一次do_one.