基于c++11的event-driven library的理解

2023-08-01 16:29:04 66

做了一个不到200行的事件驱动库，基于c++11标准，header-only，跨平台。支持自定义事件，通过wake_up函数异步唤醒。写这个库的动机是想为之前自己写的日志库提供日志回滚机制。

github：https://github.com/chloro-pn/event_pool

event_pool

基本介绍

aheader-onlyevent-drivenlibrarybasedonc++11.

一个基于c++11标准，仅需要头文件的事件驱动库:)。

使用方法：

创建event_pool对象并申请一个线程做事件处理，在该线程中调用run函数。

//runtheevent_pool.
std::shared_ptrev(newevent_pool());
std::threadth([=]()->void{
ev->run();
});

创建event_handle和time_handle对象并设置id_，type_,回调函数func_，上下文args_（如果是time_handle则还要设置触发时间）等，push进event_pool对象。

//createtime_handle.
std::shared_ptrh(newtime_handle());
h->id_="timertest";
h->type_=time_handle::type::duration;
h->duration_=seconds(2);
h->args_=nullptr;
h->func_=[](std::shared_ptrself)->void{
std::cout<id_<<"wakeup!"<eh(newevent_handle());
eh->id_="backcout";
eh->type_=event_handle::type::every;
eh->args_=nullptr;
eh->func_=[](std::shared_ptrself)->void{
std::cout<id_<<"wakeup!"<push_timer(h);
ev->push_event(eh);

在需要触发事件的时候调用wake_up函数（time_handle没有wake_up函数，等待时间到达自动触发）。当需要关闭event_pool时，调用stop函数，然后回收线程，没有来得及处理的事件会被丢弃，即使当event_pool对象完全销毁后，仍然可以调用wake_up函数，此时会直接返回。

while(true){
charbuf[1024];
gets(buf);
if(buf[0]=='q'){
ev->stop();//stoptheevent_pool.
break;
}
eh->wake_up();
}
th.join();

使用指南：

所有对象均需使用std::shared_ptr创建。
每个time_handle对象和event_handle对象只能push进一个event_pool对象。
event_handle对象可设置两种类型：every和once，every类型允许不限次数的wake_up,event_pool会处理每次wake_up，而once类型只能被唤醒一次，但允许多次调用wake_up函数（线程安全），这意味着可以在多个线程并发的触发事件。
time_handle对象可设置两种类型：duration和time_point，其中duration类型通过设置duration_成员来指定从此刻开始，每间隔多少时间就触发一次。time_point类型通过设置time_point_成员来指定在哪个时刻仅触发一次。
回调函数的输入参数就是该事件对象本身，你可以通过其访问设置的id_，type_，args_等等。
event_pool的run函数可以在多个线程并发执行（maybe？），这一点暂且不保证。

特点：

1.轻量级，200行源代码，语言层面的跨平台，基于c++11标准。

2.仅需要头文件，即拿即用。

todo:

定义更便于使用，减少出错概率的接口。
补充测试。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。

声明：本文内容来源于网络，版权归原作者所有，内容由互联网用户自发贡献自行上传，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任。如果您发现有涉嫌版权的内容，欢迎发送邮件至：czq8825#qq.com（发邮件时，请将#更换为@）进行举报，并提供相关证据，一经查实，本站将立刻删除涉嫌侵权内容。

基于c++11的event-driven library的理解

热门推荐

随机推荐