1、創建IOCP
ACE_WIN32_Proactor::ACE_WIN32_Proactor (size_t number_of_threads,
int used_with_reactor_event_loop)
: completion_port_ (0),
// This *MUST* be 0, *NOT* ACE_INVALID_HANDLE !!!
number_of_threads_ (static_cast<DWORD> (number_of_threads)),
used_with_reactor_event_loop_ (used_with_reactor_event_loop)
{
// Create the completion port.
this->completion_port_ = ::CreateIoCompletionPort (INVALID_HANDLE_VALUE,
0,
0,
this->number_of_threads_);
//...
}
2、將一個句柄同完成端口關聯到一起
int
ACE_WIN32_Proactor::register_handle (ACE_HANDLE handle,
const void *completion_key)
{
#if defined (_MSC_VER) && (_MSC_VER < 1300)
ULONG comp_key (reinterpret_cast<ULONG> (completion_key));
#else
ULONG_PTR comp_key (reinterpret_cast<ULONG_PTR> (completion_key));
#endif
// No locking is needed here as no state changes.
ACE_HANDLE cp = ::CreateIoCompletionPort (handle,
this->completion_port_,
comp_key,
this->number_of_threads_);
//...
}
3、投遞一個（或多個）異步操作
4、在完成端口上等待
int
ACE_WIN32_Proactor::handle_events (unsigned long milli_seconds)
{
ACE_OVERLAPPED *overlapped = 0;
u_long bytes_transferred = 0;
#if defined (_MSC_VER) && (_MSC_VER < 1300)
ULONG completion_key = 0;
#else
ULONG_PTR completion_key = 0;
#endif
// Get the next asynchronous operation that completes
BOOL result = ::GetQueuedCompletionStatus (this->completion_port_,
&bytes_transferred,
&completion_key,
&overlapped,
milli_seconds);
//Check errors
//Execute the completion handler…
this->application_specific_code (asynch_result,
static_cast<size_t> (bytes_transferred),
(void *) completion_key,
result_err);
return 1;
}
posted on 2007-08-17 12:01
聶文龍 閱讀(408)
評論(0) 編輯 收藏 引用 所屬分類:
net work