Смущает, когда boost :: asio :: io_service запускает метод блокирует / разблокирует
Будучи абсолютным новичком в Boost.Asio, я запутался сio_service::run()
, Я был бы признателен, если бы кто-то мог объяснить мне, когда этот метод блокирует / разблокирует. Документация гласит:
run()
функциональные блоки, пока не завершится вся работа и не будет больше обработчиков для отправки или покаio_service
был остановлен
Несколько потоков могут вызыватьrun()
функция для создания пула потоков, из которыхio_service
может выполнять обработчики. Все потоки, которые ожидают в пуле, эквивалентны иio_service
может выбрать любой из них для вызова обработчика.
Нормальный выход изrun()
Функция подразумевает, чтоio_service
объект остановлен (stopped()
функция возвращает true). Последующие звонкиrun()
, run_one()
, poll()
или жеpoll_one()
вернется немедленно, если нет предварительного звонкаreset()
.
Что означает следующее утверждение?
[...] больше не нужно отправлять обработчиков [...]
Пытаясь понять поведениеio_service::run()
Я сталкивался с этимпример (пример 3а). Внутри него я наблюдаюio_service->run()
блокирует и ждет заказов на работу.
// WorkerThread invines io_service->run()
void WorkerThread(boost::shared_ptr<boost::asio::io_service> io_service);
void CalculateFib(size_t);
boost::shared_ptr<boost::asio::io_service> io_service(
new boost::asio::io_service);
boost::shared_ptr<boost::asio::io_service::work> work(
new boost::asio::io_service::work(*io_service));
// ...
boost::thread_group worker_threads;
for(int x = 0; x < 2; ++x)
{
worker_threads.create_thread(boost::bind(&WorkerThread, io_service));
}
io_service->post( boost::bind(CalculateFib, 3));
io_service->post( boost::bind(CalculateFib, 4));
io_service->post( boost::bind(CalculateFib, 5));
work.reset();
worker_threads.join_all();
Однако в следующем коде, над которым я работал, клиент подключается с использованием TCP / IP и блоков метода выполнения, пока данные не будут получены асинхронно.
typedef boost::asio::ip::tcp tcp;
boost::shared_ptr<boost::asio::io_service> io_service(
new boost::asio::io_service);
boost::shared_ptr<tcp::socket> socket(new tcp::socket(*io_service));
// Connect to 127.0.0.1:9100.
tcp::resolver resolver(*io_service);
tcp::resolver::query query("127.0.0.1",
boost::lexical_cast< std::string >(9100));
tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
socket->connect(endpoint_iterator->endpoint());
// Just blocks here until a message is received.
socket->async_receive(boost::asio::buffer(buf_client, 3000), 0,
ClientReceiveEvent);
io_service->run();
// Write response.
boost::system::error_code ignored_error;
std::cout << "Sending message \n";
boost::asio::write(*socket, boost::asio::buffer("some data"), ignored_error);
Любое объяснениеrun()
это описывает его поведение в двух примерах ниже.