0

我想做的是休闲：所以我有 4 个线程。并为每个线程创建一个 IOCP。在线程函数中，我在 GetQueuedCompletionStatus(INIFINIT) 上等待以获取工作，然后对其进行处理，然后再次等待。

因此，如果我想向特定线程提交作业，我只需在其 IOCP 上使用 PostQueuedCompletionStatus。

但我想要的是拥有一个主 IOCP 和线程函数内部。我在主 IOCP 上 GetQueuedCompletionStatus ，所以当我在主 IOCP 上发布作业时，随机线程获取并处理它，但我仍然想为特定线程发送特定作业。我怎样才能做到这一点？谢谢！谢谢。

4

1 回答 1

0

好的，我自己做的，谢谢。

这是我写的 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;
    }
}
于 2016-12-05T19:09:04.633 回答