René's URL Explorer Experiment

{"@context":"https://schema.org","@type":"DiscussionForumPosting","headline":"Can you provide an interface that calls back on the main thread?","articleBody":"Hello, I am a game server developer. When we use cpp_redis, there will be a need to call back on the main thread.\r\n\r\nAt present, I have sealed it with asio to temporarily meet the needs. Would like to ask if the official can provide such an interface. Or there are others with similar needs.\r\nMy own example: https://github.com/brinkqiang/dmredispp\r\n\r\n```\r\n#include \u003ccpp_redis/cpp_redis\u003e\r\n\r\n#include \u003ciostream\u003e\r\n\r\n#ifdef _WIN32\r\n#include \u003cWinsock2.h\u003e\r\n#endif /* _WIN32 */\r\n#include \"dmevent/dmevent_module.h\"\r\n\r\n\r\nint\r\nmain(void) {\r\n#ifdef _WIN32\r\n    //! Windows netword DLL init\r\n    WORD version = MAKEWORD(2, 2);\r\n    WSADATA data;\r\n\r\n    if (WSAStartup(version, \u0026data) != 0) {\r\n        std::cerr \u003c\u003c \"WSAStartup() failure\" \u003c\u003c std::endl;\r\n        return -1;\r\n    }\r\n#endif /* _WIN32 */\r\n\r\n    DMEVENT_INIT();\r\n    DMEVENT_BEGIN\r\n    {\r\n        fmt::print(\"-------------------------------------------- -------------------\\n\");\r\n        fmt::print(\"{} dmevent loop {} ...\\n\", DMGetExeName(), \"running\");\r\n        fmt::print(\"-------------------------------------------- -------------------\\n\");\r\n    }\r\n    DMEVENT_END;\r\n\r\n\r\n    //! Enable logging\r\n    cpp_redis::active_logger = std::unique_ptr\u003ccpp_redis::logger\u003e(new cpp_redis::logger);\r\n\r\n    cpp_redis::client client;\r\n\r\n    client.connect(\"127.0.0.1\", 6379, [\u0026](const std::string\u0026 host, std::size_t port, cpp_redis::client::connect_state status) {\r\n        DMEVENT_BEGIN\r\n        {\r\n            if (status == cpp_redis::client::connect_state::dropped) {\r\n                fmt::print(\"client disconnected from {}:{} isMain:{}\\n\", host, port, isMain());\r\n            }\r\n        }\r\n        DMEVENT_END;\r\n    });\r\n\r\n    int roleid = 0x1234;\r\n    // same as client. send({ \"SET\", \"hello\", \"42\" }, ...)\r\n    client.set(\"hello\", \"42\", [\u0026](cpp_redis::reply\u0026 reply) {\r\n        DMEVENT_BEGIN\r\n        {\r\n            fmt::print(\"set hello 42: {} roleid: {} isMain:{}\\n\", reply, roleid, isMain());\r\n        }\r\n        DMEVENT_END;\r\n    });\r\n\r\n    // same as client. send({ \"DECRBY\", \"hello\", 12 }, ...)\r\n    client.decrby(\"hello\", 12, [\u0026](cpp_redis::reply\u0026 reply) {\r\n        DMEVENT_BEGIN\r\n        {\r\n            fmt::print(\"decrby hello 12: {} roleid: {} isMain:{}\\n\", reply, roleid, isMain());\r\n        }\r\n        DMEVENT_END;\r\n    });\r\n\r\n    // same as client. send({ \"GET\", \"hello\" }, ...)\r\n    client.get(\"hello\", [\u0026](cpp_redis::reply\u0026 reply) {\r\n        DMEVENT_BEGIN\r\n        {\r\n            fmt::print(\"get hello: {} roleid: {} isMain:{}\\n\", reply, roleid, isMain());\r\n        }\r\n        DMEVENT_END;\r\n    });\r\n\r\n    // commands are pipelined and only sent when client.commit() is called\r\n    client.commit();\r\n\r\n    DMEVENT_RUN_UNTIL();\r\n    // synchronous commit, no timeout\r\n    //client.sync_commit();\r\n\r\n    // synchronous commit, timeout\r\n    // client.sync_commit(std::chrono::milliseconds(100));\r\n\r\n#ifdef _WIN32\r\n    WSACleanup();\r\n#endif /* _WIN32 */\r\n\r\n    return 0;\r\n}\r\n```","author":{"url":"https://github.com/brinkqiang","@type":"Person","name":"brinkqiang"},"datePublished":"2022-03-23T10:09:43.000Z","interactionStatistic":{"@type":"InteractionCounter","interactionType":"https://schema.org/CommentAction","userInteractionCount":0},"url":"https://github.com/90/cpp_redis/issues/90"}