此websocket++示例中的线程安全用户数据

Question

websocket++的This示例正是我想在其核心所做的事情。

虽然websocketpp::connection_hdl可以很容易地跟踪用户，但我需要保留更多关于他们的信息，就像stack如何跟踪我们正在查看的页面以更新投票、评论、答案、左上角的消息等。

我刚刚发现std::queue不是完全线程安全的does .push() fail or wait while locked in this code example?，我将找到一种方法(可能使用堆栈q)在boost::lockfree::queue Thread-Safe C/C++ queue optimized for push中工作。更重要的是，我刚刚发现线程安全的向量在Threadsafe Vector class for C++中要麻烦得多

从第一个链接中的代码可以看出，如何以线程安全的方式跟踪用户数据(比如当前查看的堆栈问题)，而不会被锁定和阻塞？

Answer 1

我实际上是在一个websocket++应用程序中自己做这件事，尽管我不使用实验分支。

我所做的是在on_open中创建一个UserData对象(我已经定义了该对象)，该对象接受构造函数中的连接。然后我把这个对象放在一个std::map<std::string, connection_hdl>上。字符串是序列化的连接，它提供了唯一标识它的方法。您可以尝试使用std::map<connection_hdl, UserData>。

当我想要找到UserData时，我只需在映射中查找连接，它就会返回UserData。

然后，为了使其线程安全，您需要在每次访问std::map时执行一个boost::unique_lock<boost::mutex>。几乎没有std类是头部感知的，所以你应该总是像这样添加卫士。

编辑：Here是稳定websocket++中的一个例子，它展示了如何做到这一点的一种方法。