Windows IOCP дерево?

То, что я хочу сделать, это следующее: у меня есть 4 темы. и для каждого потока я создаю IOCP. внутри функции потока я жду GetQueuedCompletionStatus(INIFINIT), чтобы получить работу, затем обработать ее и затем снова ждать.

Поэтому, если я хочу отправить задание в определенный поток, я просто отправляю PostQueuedCompletionStatus на свой IOCP.

Но то, что я хочу, это иметь как основной IOCP и внутри функции потока. i GetQueuedCompletionStatus на главном IOCP, поэтому, когда я размещаю задание на главном IOCP, случайный поток получает задание и обрабатывает его, но я все еще хочу отправить конкретные задания для определенного потока. Как я могу это сделать? Спасибо! Благодарю.

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;
    }
}
Другие вопросы по тегам