我想做的是休眠:所以我有4个线程。并为每个线程创建一个IOCP。在线程函数中,我等待GetQueuedCompletionStatus(INIFINIT)获取一个作业,然后处理它,然后再次等待。
因此,如果我想提交一个作业到一个特定的线程,我只需要在它的IOCP上使用PostQueuedCompletionStatus。
但我想要的是有一个像主IOCP和线程内的函数。我在主IOCP上执行GetQueuedCompletionStatus,所以当我在主IOCP上发布作业时,随机线程获取作业并处理它,但我仍然希望为特定线程发送特定作业。我该怎么做呢?谢谢!谢谢。
发布于 2016-12-06 03:09:05
好的,我自己做的,谢谢。
这是我写的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;
}
}https://stackoverflow.com/questions/40977401
复制相似问题