C++怎么实现一个简单的事件循环(Event Loop)_C++异步IO模型与Proactor模式-C++-PHP中文网

C++怎么实现一个简单的事件循环(Event Loop)_C++异步IO模型与Proactor模式

下次还敢

发布： 2025-11-22 13:30:06

原创

485人浏览过

答案：基于epoll和线程池实现C++事件循环，通过注册文件描述符事件并结合eventfd通知机制模拟Proactor模式，实现异步IO操作的高效调度与回调处理。

c++怎么实现一个简单的事件循环(event loop)_c++异步io模型与proactor模式

实现一个简单的事件循环（Event Loop）在C++中是构建异步系统的基础，尤其适用于网络服务器、GUI框架或需要处理大量I/O操作的场景。结合异步IO模型和Proactor模式，可以高效地管理并发任务而无需为每个连接创建线程。

事件循环的基本原理

事件循环的核心是一个持续运行的循环，它监听多个文件描述符（如套接字）上的事件（可读、可写、异常），当某个事件发生时，调用对应的回调函数进行处理。

在Linux下通常使用epoll（也可用poll或kqueue on BSD/macOS）来实现高效的多路复用IO。

Proactor模式则是主动发起异步操作，并在操作完成时通知应用程序——这与Reactor模式（先等待事件再处理）不同。C++标准库目前没有原生支持异步IO（如POSIX AIO或Windows IOCP），但我们可以模拟Proactor的行为通过线程池+事件循环的方式。

立即学习“C++免费学习笔记（深入）”；

使用epoll实现基本事件循环

以下是一个简化版的基于epoll的事件循环示例：

#include <sys/epoll.h>
#include <fcntl.h>
#include <unistd.h>
#include <functional>
#include <unordered_map>
#include <vector>
#include <thread>
<p>class EventLoop {
public:
using Callback = std::function<void()>;</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">EventLoop() : epoll_fd_(epoll_create1(0)), running_(false) {}

~EventLoop() {
    if (epoll_fd_ >= 0) close(epoll_fd_);
}

void AddFd(int fd, Callback read_cb) {
    epoll_event ev;
    ev.events = EPOLLIN;
    ev.data.fd = fd;
    ev.data.ptr = new Callback(std::move(read_cb));
    epoll_ctl(epoll_fd_, EPOLL_CTL_ADD, fd, &ev);
}

void Run() {
    running_ = true;
    epoll_event events[10];
    while (running_) {
        int n = epoll_wait(epoll_fd_, events, 10, 1000); // 1秒超时
        for (int i = 0; i < n; ++i) {
            auto* cb = static_cast<Callback*>(events[i].data.ptr);
            if (cb) (*cb)();
        }
    }
}

void Stop() {
    running_ = false;
}

登录后复制

private: int epollfd; bool running_; };

这个例子中，我们注册文件描述符及其读事件回调。每次epoll触发后执行对应回调。注意：实际项目中应妥善管理回调生命周期（比如用智能指针或句柄机制）。

模拟Proactor模式：异步写入示例

真正的Proactor由操作系统完成IO并通知结果，但在大多数Unix系统上需依赖线程模拟。下面展示如何用线程池提交写操作，完成后由事件循环调度回调。

BlessAI

Bless AI 提供五个独特的功能：每日问候、庆祝问候、祝福、祷告和名言的文本生成和图片生成。

查看详情

#include <thread>
#include <queue>
#include <mutex>
#include <condition_variable>
<p>class ThreadPool {
public:
void Start(int threads = 2) {
for (int i = 0; i < threads; ++i) {
workers_.emplace_back([this] {
while (true) {
std::unique_lock<std::mutex> lock(queue<em>mutex</em>);
cv<em>.wait(lock, [this]{ return !tasks</em>.empty() || stop<em>; });
if (stop</em> && tasks<em>.empty()) break;
auto task = std::move(tasks</em>.front());
tasks_.pop();
lock.unlock();
task();
}
});
}
}</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">void Post(std::function<void()> task) {
    {
        std::unique_lock<std::mutex> lock(queue_mutex_);
        tasks_.push(std::move(task));
    }
    cv_.notify_one();
}

void Stop() {
    {
        std::unique_lock<std::mutex> lock(queue_mutex_);
        stop_ = true;
    }
    cv_.notify_all();
    for (auto& w : workers_) w.join();
}

登录后复制

private: std::vector<std::thread> workers; std::queue<std::function<void()>> tasks; std::mutex queuemutex; std::conditionvariable cv; bool stop_ = false; };

然后将异步操作封装成“发起即返回”，完成时通过eventfd或管道唤醒主事件循环：

// 使用eventfd通知事件循环有完成事件
int notify_fd = eventfd(0, EFD_CLOEXEC);
<p>// 在事件循环中监听notify_fd
loop.AddFd(notify_fd, [&]() {
uint64_t one;
read(notify_fd, &one, sizeof(one));
printf("Async write completed!\n");
});</p><p>// 提交异步写任务
thread_pool.Post([&]() {
// 模拟耗时写操作
sleep(1);
write(socket_fd, "response", 8);</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">// 通知事件循环完成
uint64_t one = 1;
write(notify_fd, &one, sizeof(one));

登录后复制

});

这种方式实现了类似Proactor的效果：发起IO时不阻塞主线程，完成时自动通知事件循环去处理后续逻辑。