Mario同步到异步的类库
Mario 是一个让编写从同步到异步的类库,它的线程安全较大,易于使用。Mario 的最基本的想法就是为了减少人员的安排,降低成本和时间投入。但是有了这个类库,操作人员就可以抽出精力做别的事情了。所以 Mario 类库能够很轻易的解决你的问题,你只需要你自己的消息功能。
引擎类型:
-
memory,这种类型就是将数据缓冲存储器留在内存里。
-
file,这种类型就是能够在本地日志路径里创建做出一个 write2file。
示例代码:
#include "mario.h" #include "consumer.h" #include "mutexlock.h" #include "port.h" /** * @brief The handler inherit from the Consumer::Handler * The processMsg is pure virtual function, so you need implementation your own * version */ class FileHandler : public mario::Consumer::Handler { public: FileHandler() {}; virtual void processMsg(const std::string &item) { log_info("consume data %s", item.data()); } }; int main() { mario::Status s; FileHandler *fh = new FileHandler(); /** * @brief * * @param 1 is the thread number * @param fh is the handler that you implement. It tell the mario how * to consume the data * * @return */ mario::Mario *m = new mario::Mario(1, fh); std::string item = "Put data in mario"; s = m->Put(item); if (!s.ok()) { log_err("Put error"); exit(-1); } delete m; delete fh; return 0; }
评论
Android-lite-goAndroid异步并发类库
LiteGo:「迷你」的Android异步并发类库LiteGo是一款基于Java语言的「异步并发类库
Android-lite-goAndroid异步并发类库
0
Android-lite-goAndroid异步并发类库
LiteGo:「迷你」的Android异步并发类库LiteGo是一款基于Java语言的「异步并发类库」,它的核心是一枚「迷你」并发器,它可以自由地设置同一时段的最大「并发」数量,等待「排队」线程数量,
Android-lite-goAndroid异步并发类库
0
Bouyei.NetFactory.net 高性能异步、同步通信库
c# 高性能大并发socket异步、同步通信库,建立独立的发送缓冲池和接收缓冲池解决发送和接收不断分配缓冲区问题,主要功能模块:支持.netcore和.netframework。tcp客户端和服务端,
Bouyei.NetFactory.net 高性能异步、同步通信库
0
Bouyei.NetFactory.net 高性能异步、同步通信库
c# 高性能大并发 socket 异步、同步通信库,建立独立的发送缓冲池和接收缓冲池解决发送和接收不
Bouyei.NetFactory.net 高性能异步、同步通信库
0