【问题标题】:Windows IOCP tree?Windows IOCP 树?
【发布时间】:2016-12-05 15:13:15
【问题描述】:
我想做的是休耕:
所以我有4个线程。并为每个线程创建一个 IOCP。
在线程函数中我等待 GetQueuedCompletionStatus(INIFINIT)
得到一份工作,然后处理它,然后再次等待。
因此,如果我想将作业提交到特定线程,我只需在其 IOCP 上使用 PostQueuedCompletionStatus。
但我想要的是拥有一个主 IOCP 和线程函数内部。我在主 IOCP 上 GetQueuedCompletionStatus ,所以当我在主 IOCP 上发布作业时,随机线程获取并处理它,但我仍然想为特定线程发送特定作业。我怎样才能做到这一点?谢谢!
谢谢。
【问题讨论】:
标签:
windows
io-completion-ports
【解决方案1】:
好的,我自己做的,谢谢。
这是我写的 post_job 函数:
bool WINAPI world_server_process_job_async(job* j)
{
if (j->type == J_W_RESOLVE)
{
for (uint32 i = 0; i < w_server.no_of_threads; i++)
if (!PostQueuedCompletionStatus(w_server.world_worker_threads[i]->iocp, sizeof(job), NULL, (LPOVERLAPPED)j))
w_server.resolve_drop_count++;
}
else
{
for (uint32 i = 0; i < w_server.no_of_threads; i++)
if (w_server.world_worker_threads[i]->state == WORKER_INACTIVE)
return PostQueuedCompletionStatus(w_server.world_worker_threads[i]->iocp, sizeof(job), NULL, (LPOVERLAPPED)j) ? true : false;
bool result = PostQueuedCompletionStatus(w_server.world_worker_threads[w_server.last_to_do_work]->iocp, sizeof(job), NULL, (LPOVERLAPPED)j) ? true : false;
if ((++w_server.last_to_do_work) >= w_server.no_of_threads) w_server.last_to_do_work = 0;
return result;
}
}