Method ProcessEvent

net/linux/CEpoll.cpp:246–291

}

void CEpoll::ProcessEvent() {
    uint32_t        wait_time = 0;
    std::vector<base::CMemSharePtr<CTimerEvent>> timer_vec;;
    std::vector<epoll_event> event_vec;
    event_vec.resize(1000);
    while (_run) {
        wait_time = _timer.TimeoutCheck(timer_vec);
        //if there is no timer event. wait until recv something
        if (wait_time == 0 && timer_vec.empty()) {
            wait_time = -1;
        } else {
            wait_time = wait_time > 0 ? wait_time : 1;
        }
        int res = epoll_wait(_epoll_handler, &*event_vec.begin(), (int)(event_vec.size()), wait_time);
        if (res == -1) {
            base::LOG_ERROR("epoll_wait faild! error :%d", errno);
        }

        if (res > 0) {
            base::LOG_DEBUG("epoll_wait get events! num :%d, TheadId : %lld", res, std::this_thread::get_id());

            _DoEvent(event_vec, res);
            _DoTaskList();
            if (!timer_vec.empty()) {
                _DoTimeoutEvent(timer_vec);
            }

        } else {
            if (!timer_vec.empty()) {
                _DoTimeoutEvent(timer_vec);
            }
            _DoTaskList();
        }
    }

    if (close(_epoll_handler) == -1) {
        base::LOG_ERROR("epoll close failed! error : %d", errno);
    }
    if (close(_pipe[0]) == -1) {
        base::LOG_ERROR("_pipe[0] close failed! error : %d", errno);
    }
    if (close(_pipe[1]) == -1) {
        base::LOG_ERROR("_pipe[1] close failed! error : %d", errno);
    }
    base::LOG_INFO("return the net io thread");
}

void CEpoll::PostTask(std::function<void(void)>& task) {
    {