Mario同步到異步的類庫(kù)

Mario 是一個(gè)讓編寫(xiě)從同步到異步的類庫(kù)，它的線程安全較大，易于使用。Mario 的最基本的想法就是為了減少人員的安排，降低成本和時(shí)間投入。但是有了這個(gè)類庫(kù)，操作人員就可以抽出精力做別的事情了。所以 Mario 類庫(kù)能夠很輕易的解決你的問(wèn)題，你只需要你自己的消息功能。

引擎類型：

• memory，這種類型就是將數(shù)據(jù)緩沖存儲(chǔ)器留在內(nèi)存里。

• file，這種類型就是能夠在本地日志路徑里創(chuàng)建做出一個(gè) 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;
}