2

我的班级接收者...它接收一些字符串并将其推送到缓冲区。

Reciever::Reciever(boost::shared_ptr<TSBuffer<std::string>> buffer, int port)
    : port(port), buffer(buffer)
{
    using namespace boost::asio;
    acceptor_ = new ip::tcp::acceptor(iosev, ip::tcp::endpoint(ip::tcp::v4(),  port));
}


Reciever::~Reciever()
{
    delete acceptor_;
}

void Reciever::run()
{
    using namespace boost::asio;
    _start();
    iosev.run();
}

void Reciever::stop()
{
    Sender s("127.0.0.1", std::string(8, '$'), port);
}

void Reciever::_start()
{
    using namespace boost::asio;
    boost::shared_ptr<ip::tcp::socket> socket(new ip::tcp::socket(iosev));
    acceptor_->async_accept(*socket, boost::bind(&Reciever::acceptHanlder, this, socket));
}

void Reciever::acceptHanlder(boost::shared_ptr<boost::asio::ip::tcp::socket> socket)
{
    std::string delim(8, '$');
    boost::system::error_code ec;
    boost::asio::streambuf strmbuf;

    boost::asio::read_until(*socket, strmbuf, delim, ec);
    std::istream is(&strmbuf);
    std::string re((std::istreambuf_iterator<char>(is)),std::istreambuf_iterator<char>());
    re.replace(re.end() - delim.size(), re.end(), "");
    if (re.size() && re != std::string(8, '$')){
        buffer->push(re);
        _start();
}

在 main() 函数中，我使用 X(uncertain) 线程将 X 字符串发送到接收器。当 Reciever::acceptHanlder 被调用 X 次（这意味着 X 字符串被处理）时，我想停止接收器（调用 Reciever::stop）。但我不知道如何确定？

4

1 回答 1

2

我看到在acceptHanlder的最后一行之前不可能调用async_accept。因此，您可以简单地在Reciever对象中实现一个计数器，并且在工作完成时不要调用_start 。当在不同的线程中使用相同的接收器时，它要复杂得多，我更喜欢使用“连接对象”范式。

您也可以使用asio::strand来限制acceptHanlder-s ，因此任何时候只有一个acceptHanlder给定的Reciever可以处于活动状态。这消除了Reciever. 所以你可以安全地调用Reciever::stop（使用相同的strand）。

于 2012-11-16T19:00:04.743 回答