Boost.Asio取消异步操作

在异步编程中, 如果某些条件不满足, 或者用户想强制取消某些IO操作, 此时也需要终止启动的异步操作. 下面给出一个常用的方法.

#include <boost/asio.hpp>
#include <iostream>
#include <thread>
#include <memory>
#include <chrono>using namespace boost;int main() {std::string raw_ip_address = "127.0.0.1";unsigned short port_num = 6768;try {asio::ip::tcp::endpoint ep(asio::ip::address::from_string(raw_ip_address),port_num);asio::io_context ioc;std::shared_ptr<asio::ip::tcp::socket> sock(new asio::ip::tcp::socket(ioc, ep.protocol()));sock->async_connect(ep,[sock](const boost::system::error_code &ec) {if (ec.value() != 0) {if (ec == asio::error::operation_aborted) {std::cout << "Operation cancelled!\n";} else {std::cout << "Error occurred!"<< " Error code = "<< ec.value()<< ". Message: "<< ec.message();}}return;});// 运行Boost.Asio的事件循环, 在新的线程启动std::thread worker_thread([&ioc]() {try {ioc.run();} catch (boost::system::system_error &e) {std::cout << "Error occurred!"<< " Error code = " << e.code()<< ". Message: " << e.what();}});// 模拟处理其它任务std::this_thread::sleep_for(std::chrono::seconds(2));sock->cancel();  // 这里会启动异步回调函数worker_thread.join();} catch (boost::system::system_error &e) {std::cout << "Main Error occurred! Error code = " << e.code()<< ". Message: " << e.what();return e.code().value();}return 0;
}

输出结果:

Error occurred! Error code = 111. Message: Connection refused

上述代码中, io_context在新线程启动的原理可以参考这个笔记

Boost.Asio取消异步操作相关推荐

Boost：异步操作，需要boost :: asio :: async_compose函数的测试程序
Boost:异步操作,需要boost :: asio :: async_compose函数的测试程序实现功能 C++实现代码实现功能 boost::asio模块,异步操作,需要boost :: a ...
Boost：异步操作，需要boost :: asio :: async_initiate函数的测试程序
Boost:异步操作,需要boost :: asio :: async_initiate函数的测试程序实现功能 C++实现代码实现功能 boost::asio模块,异步操作,需要boost :: ...
Boost asio 官方教程简介
1. 概述本章介绍了 Boost C++ 库 Asio,它是异步输入输出的核心. 名字本身就说明了一切:Asio 意即异步输入/输出. 该库可以让 C++ 异步地处理数据,且平台独立. 异步数据处理 ...
Boost.Asio基本原理
Boost.Asio基本原理这一章涵盖了使用Boost.Asio时必须知道的一些事情.我们也将深入研究比同步编程更复杂.更有乐趣的异步编程. 网络API 这一部分包含了当使用Boost.Asio编写 ...
Boost.Asio技术文档
文章来源:http://blog.csdn.net/henreash/article/details/7469707 Boost.Asio是一个跨平台的网络及底层IO的C++编程库,它使用现代C++手 ...

Boost.Asio取消异步操作

Boost.Asio取消异步操作相关推荐

最新文章

热门文章