c++ - 使用 Boost Asio 套接字为双端队列调用移动构造函数时出现问题

Question

我正在尝试编写一个多线程 Web 服务器，但在将已接受的 boost::asio::ip::tcp::socket 对象从我的父线程传递到我的 child 线程。

我目前的解决方案非常笨拙，因为我不认为我理解正确的面向类的设计。尽管如此，在我继续前进并使其更清晰之前，我还是想让它与我笨拙的实现一起工作。

以下是出现问题的相关文件:

// consts_globs_shared.h
// User holds a username, and other string related info for this session
using boost::asio::ip::tcp;
std::map<
         std::string,
         std::deque<std::tuple<User, tcp::socket, std::deque<std::string>>
         > chan_newusers;
std::mutex newusers_lock;  

.

// server.cpp
#include "consts_globs_shared.h"
...
tcp::socket sock(io_service);
acceptor.accept(sock);       // acceptor defined prior
...

std::unique_lock<std::mutex> lck(newuser_lock);
if (!chan_newusers.count(channel))
    chan_newusers[channel]; // initialize
chan_newusers[channel].push_back(std::make_tuple(client,
                                                 std::move(sock),
                                                 temp_msgs));  

.

// servlet.cpp
#include "consts_globs_shared.h"
...
for (auto it = chan_newusers[chan].begin(); it != chan_newusers[chan].end(); ++it) {
    tcp::endpoint endpt = std::get<0>(*it).get_endpt(); // Users carry socket endpoint with them since that's copy constructible
    tcp::socket temp(std::move(std::get<1>(*it)));
    // have a class called servlet that holds a map called end_msgs
    // @key: socket endpoints, @value: sockets
    servlet.end_msgs[endpt]; // instantiate
    servlet.end_msgs[endpt] = std::move(temp);
}

这个想法是服务器获取传入连接，将该套接字移动到全局 map 上，然后通知管理该聊天室的子线程有一个新用户需要获取。子线程从全局列表中抓取。我尝试省略不相关的代码，但我对如何实现这一点感到非常困惑。

我认为，当我将元组推送到映射中的双端队列时，元组会按值进行复制，因为我认为双端队列就是这样获取新元素的，而不是移动构造的。因此元组中的元素然后按值复制，并尝试按值复制套接字。但我不确定如何诊断是否发生了这种情况，也不确定如何修复它。

如果有任何建议，我将不胜感激。如果这篇文章可以变得更清晰或更容易理解，请告诉我。

编辑:这是我现在遇到的错误的一部分。这是巨大的，但我只会磨练看起来最相关的东西。

/usr/include/c++/5/ext/new_allocator.h:120:4: error: use of deleted 
function ‘constexpr std::pair<_T1, _T2>::pair(const std::pair<_T1, _T2>&) [with _T1 = const 
boost::asio::ip::basic_endpoint<boost::asio::ip::tcp>; _T2 = 
boost::asio::basic_stream_socket<boost::asio::ip::tcp>]’  

.

/usr/include/c++/5/ext/new_allocator.h:120:4: error: use of deleted 
function ‘constexpr std::pair<_T1, _T2>::pair(const std::pair<_T1, _T2>&) [with _T1 = const 
boost::asio::ip::basic_endpoint<boost::asio::ip::tcp>; _T2 = 
boost::asio::basic_stream_socket<boost::asio::ip::tcp>]’

Answer 1

如果包含您遇到的错误消息会很有帮助，因为您的代码不是独立的。

I think that, when I make the tuple to be pushed onto the deque in the map, the tuple gets copied by value since that's how I believe deques grab new elements

你离目标不远

, rather than move constructed.

嗯。这取决于!如你can see push_back 在接受右值引用的 c++11 中获得了一个新的重载。如果您使用它，那么肯定会发生移动构造。

注意 c++11 also added emplace_back哪个就地构建元组

示例

我把你的样本做成独立的，有3个编译版本push_back或emplace_back信息:

    auto& chan = chan_newusers[channel];
    chan.emplace_back(client, std::move(sock), std::move(temp_msgs));  
    // // ALSO:
    // chan.push_back(NewUserData(client, std::move(sock), std::move(temp_msgs)));  

    // // ALSO:
    // chan.push_back({client, std::move(sock), std::move(temp_msgs)});  

Note obviously, you can only move once, so uncomment only 1 of the three lines :)

完整 list

Live On Coliru

#include <boost/asio.hpp>
#include <map>
#include <deque>
#include <tuple>
#include <string>
#include <mutex>

// User holds a username, and other string related info for this session
struct User {
    std::string name;
    // ...
};

// consts_globs_shared.h
using boost::asio::ip::tcp;

using ChannelId = std::string;
using NewUserData = std::tuple<User, tcp::socket, std::deque<std::string>>;

std::map<ChannelId, std::deque<NewUserData> > chan_newusers;
std::mutex newusers_lock;  

struct SomethingInServerCpp {
    boost::asio::io_service io_service;

    void foo() {
        // server.cpp
        //...
        tcp::socket sock(io_service);
        tcp::acceptor acceptor(sock.get_io_service());
        acceptor.bind({{}, 6767});
        acceptor.accept(sock);       // acceptor defined prior
        //...
        User client { "user1" };
        std::string channel = "some_channel_from_the_request_I_guess";
        std::deque<std::string> temp_msgs { "foo", "bar", "qux" };

        std::unique_lock<std::mutex> lck(newusers_lock);

        {
            auto& chan = chan_newusers[channel];
            chan.emplace_back(client, std::move(sock), std::move(temp_msgs));  
            // // ALSO:
            // chan.push_back(NewUserData(client, std::move(sock), std::move(temp_msgs)));  
            // // ALSO:
            // chan.push_back({client, std::move(sock), std::move(temp_msgs)});  
        }
    }
};

int main() {
}