1

Нашел пример ассинхронного tcp сервера на boost::asio. Каким образом можно приостановить выполнение сопрограммы и ассинхронно подождать возобновления по выполнению операции в другом потоке?

#include <boost/asio.hpp>
#include <boost/asio/spawn.hpp>
#include <boost/algorithm/string/predicate.hpp>
#include <boost/thread.hpp>
#include <iostream>
#include <thread>

namespace asio = boost::asio;
using boost::asio::ip::tcp;
using std::begin;
using std::end;

int main()
{
    asio::io_service iosvc;
    tcp::socket s(iosvc);
    tcp::resolver r(iosvc);

    tcp::acceptor a(iosvc, tcp::endpoint(tcp::v4(), 6767));

    a.accept(s);
    {
        asio::spawn(iosvc, [&iosvc,&s](asio::yield_context yield)
        {
            char data[256];
            while (s.is_open())
            {
                size_t n = s.async_read_some(boost::asio::buffer(data), yield);

                if (boost::algorithm::starts_with(data, "async"))
                {

                    //TODO: асинхронно педождать завершения операции в другом потоке


                    std::thread t([](){
                        //Долгая операция в другом потоке или io_service
                        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
                    });
                    t.detach();

                    boost::asio::async_write(s, boost::asio::buffer(data, n), yield);
                } else
                {
                    std::cout << "Received unknown command '" << std::string(data, data+n) << "'\n";
                }
            }
        });
    }

    iosvc.run();
}
3
  • Уточните, что подразумевается под словосочетанием асинхронное ожидание? Родительский поток должен остановится и подождать пока закончиться выполнение дочернего (в примере std::thread t) ?
    – acade
    Commented 29 сент. 2018 в 10:19
  • @acade, сопрограмма должна приостановиться, в это время io_service занимается другими событиями(не блокируясь). А по завершению длительной операции в отдельном потоке должен быть какой-то механизм по возобновлению сопрограммы. Если писать без сопрограмм - мы бы вызывали iosvc.post() с полученным колбеком по завершению операции.
    – NoTrust
    Commented 29 сент. 2018 в 10:22
  • @acade, так же как мы в async_write передаем yield, и по завершению записи нас возобновляют. Вот я и хочу сделать такую функцию
    – NoTrust
    Commented 29 сент. 2018 в 10:26

1 ответ 1

0

Используйте boost::asio::channel. В рабочем потоке отправляйте сообщение в канал после окончания, а в сопроцедуре ожидайте:

#include <boost/asio.hpp>
#include <boost/asio/spawn.hpp>
#include <boost/algorithm/string/predicate.hpp>
#include <boost/thread.hpp>
#include <iostream>
#include <thread>
#include <boost/asio/experimental/concurrent_channel.hpp>

namespace asio = boost::asio;
using boost::asio::ip::tcp;
using std::begin;
using std::end;

int main()
{
    asio::io_service iosvc;
    tcp::socket s(iosvc);
    tcp::resolver r(iosvc);

    tcp::acceptor a(iosvc, tcp::endpoint(tcp::v4(), 6767));

    a.accept(s);
    {
        asio::spawn(iosvc, [&iosvc,&s](asio::yield_context yield)
        {
            char data[256];
            while (s.is_open())
            {
                size_t n = s.async_read_some(boost::asio::buffer(data), yield);

                if (boost::algorithm::starts_with(data, "async"))
                {
                    boost::asio::experimental::concurrent_channel<void(boost::system::error_code, bool)> ch(iosvc);

                    std::thread t([&ch](){
                        //Долгая операция в другом потоке или io_service
                        std::this_thread::sleep_for(std::chrono::milliseconds(1000));
                        // проверить возвращаемое значение и перезапустить, если что 
                        ch.try_send(boost::system::error_code{}, true);
                    });
                    t.detach();

                    // асинхронно подождать завершения операции в другом потоке
                    ch.async_receive(yield);

                    boost::asio::async_write(s, boost::asio::buffer(data, n), yield);
                } else
                {
                    std::cout << "Received unknown command '" << std::string(data, data+n) << "'\n";
                }
            }
        });
    }

    iosvc.run();
}

Есть еще вариант с парой сокетов.


ch.try_send() может выйти с ошибкой, надо бы проверить и перезапустить:

    while (!ch.try_send(boost::system::error_code{}, true))
        std::this_thread::sleep_for(std::chrono::milliseconds(100));

В коде до вызова ch.try_send() может быть выброшено исключение. Вероятно, исключения обрабатываются в едином месте, возле вызова iosvc.run(). Тогда сопроцедура зависнет. Надо обернуть вызов try_send в блок исполнения при выходе из области видимости:

    BOOST_SCOPE_EXIT(&ch)
    {
        ch.try_send(boost::system::error_code{}, true);
    } BOOST_SCOPE_EXIT_END

Отдельный тред создавать не айс, лучше закинуть таск в io_service:

    iosvc.post([&ch](){
        //Долгая операция в другом потоке или io_service
        sql.query(...);
        ch.try_send(boost::system::error_code{}, true);
    });

Выполнять дочерние задачи в том же io_service лучше с точки зрения управляемости приоритетами тредпула и с точки зрения обработки исключений.

0

Ваш ответ

Нажимая «Отправить ответ», вы соглашаетесь с условиями пользования и подтверждаете, что прочитали политику конфиденциальности.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.