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;
}
}