drogon/lib/tests/CacheMapTest2.cc

#include <drogon/CacheMap.h>
#include <drogon/utils/Utilities.h>
#include <iostream>
#include <memory>
#include <string>
#include <thread>
#include <trantor/net/EventLoopThread.h>
#include <trantor/utils/Logger.h>

int main()
{
    trantor::Logger::setLogLevel(trantor::Logger::kTrace);
    trantor::EventLoopThread loopThread;
    loopThread.run();

    auto loop = loopThread.getLoop();
    std::shared_ptr<drogon::CacheMap<std::string, std::string>> main_cachePtr;
    auto now = trantor::Date::date();
    loop->runAt(now.after(1).roundSecond(), [=, &main_cachePtr]() {
        std::shared_ptr<drogon::CacheMap<std::string, std::string>> cachePtr =
            std::make_shared<drogon::CacheMap<std::string, std::string>>(loop,
                                                                         0.1,
                                                                         3,
                                                                         50);
        main_cachePtr = cachePtr;
        LOG_DEBUG << "insert :usecount=" << main_cachePtr.use_count();
        cachePtr->insert("1", "1", 3, [=]() {
            LOG_DEBUG << "timeout!erase 1!";
        });
        cachePtr->insert("2", "2", 10, []() { LOG_DEBUG << "2 timeout"; });
    });
    trantor::EventLoop mainLoop;
    mainLoop.runAt(now.after(3).roundSecond().after(0.0013), [&]() {
        (*main_cachePtr)["new"] = "new";
        if (main_cachePtr->find("1"))
        {
            LOG_DEBUG << "find item 1:" << (*main_cachePtr)["1"];
            (*main_cachePtr)["1"] = "22";
            LOG_DEBUG << (*main_cachePtr)["1"];
        }
        else
        {
            LOG_DEBUG << "can't find item 1";
        }
    });
    mainLoop.runAfter(8, [&]() { mainLoop.quit(); });
    mainLoop.loop();
}