【问题标题】: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;
        }
    }
    

    【讨论】:

      猜你喜欢
      • 2011-11-10
      • 1970-01-01
      • 1970-01-01
      • 2021-10-03
      • 2012-04-23
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多