首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >async_connect是不可取消的吗?

async_connect是不可取消的吗?
EN

Stack Overflow用户
提问于 2019-10-26 20:04:25
回答 1查看 1.4K关注 0票数 1

短故事:在socket.cancel()之后调用socket.async_connect(...),即调用完成处理程序;但是对于asio::async_connect(socket, ...)之后的socket.cancel(),完成处理程序从未被调用过。

长话短说,这里有一个完整的源代码:

代码语言:javascript
复制
#include <iostream>
#include <vector>
#include <chrono>
#include <ctime>
#include <boost/asio.hpp>

namespace sys = boost::system;
namespace asio = boost::asio;
using tcp = asio::ip::tcp;

static const int count = 10;

struct client_t {
    using sock_ptr_t = std::unique_ptr<tcp::socket>;
    using resolve_results_t = tcp::resolver::results_type;

    client_t(asio::io_context& io_context_): io_context{io_context_}, resolver{io_context}{
    }

    void start() {
        tcp::endpoint endpoint(asio::ip::address::from_string("93.184.216.34"), 80);
        resolver.async_resolve("www.example.com", "80", [&](auto ec, auto results){
           this->on_resolve(ec, results);
        });
    }

    void on_resolve(const sys::error_code& ec, resolve_results_t results) {
        auto now = std::chrono::system_clock::now();
        time_t tt = std::chrono::system_clock::to_time_t(now);
        std::cerr << "on_resolve " << this  << " " << ec.message() << ", at " << ctime(&tt);
        if (!ec) {
            sock = std::make_unique<tcp::socket>(io_context);
            /*
            sock->async_connect(*results.begin(), [this](auto& ec){
                this->on_connect(ec);
            });
            */
            asio::async_connect(*sock, results.begin(), results.end(), [this](auto& ec, auto it){
                this->on_connect(ec);
            });
        }
    }

    void on_connect(const sys::error_code& ec) {
        auto now = std::chrono::system_clock::now();
        time_t tt = std::chrono::system_clock::to_time_t(now);
        std::cerr << "on_connect " << this  << " " << ec.message() << ", at " << ctime(&tt);
    }


    void cancel() {
        std::cout << "cancellation attempt for " << this << "\n";
        if (sock) {
            sys::error_code ec;
            sock->cancel(ec);
            std::cout << "cancellation result: " << ec.message() << "\n";
        }
    }

    asio::io_context& io_context;
    sock_ptr_t sock;
    tcp::resolver resolver;

};

using client_ptr_t = std::unique_ptr<client_t>;
using container_t = std::vector<client_ptr_t>;

int main() {
    asio::io_context io_context;
    std::cerr << "starting\n";

    container_t container;
    for(int i = 0; i < count; ++i) {
        auto client = std::make_unique<client_t>(io_context);
        client->start();
        container.emplace_back(std::move(client));
    }

    boost::asio::deadline_timer timer(io_context);

    timer.expires_from_now(boost::posix_time::milliseconds(5));
    timer.async_wait([&](auto& ec){
        for(auto& it : container) {
            it->cancel();
        }
        auto now = std::chrono::system_clock::now();
        time_t tt = std::chrono::system_clock::to_time_t(now);
        std::cout << "cancelled at " << ctime(&tt);
    });

    io_context.run();
    std::cerr << "finished\n";

    return 0;
}

输出样本是:

代码语言:javascript
复制
starting
on_resolve 0x985000 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x9854c0 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985600 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985730 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985830 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985700 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985a90 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985bb0 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985cd0 Success, at Sat Oct 26 22:59:22 2019
on_resolve 0x985e80 Success, at Sat Oct 26 22:59:22 2019
cancellation attempt for 0x985000
cancellation result: Success
cancellation attempt for 0x9854c0
cancellation result: Success
cancellation attempt for 0x985600
cancellation result: Success
cancellation attempt for 0x985730
cancellation result: Success
cancellation attempt for 0x985830
cancellation result: Success
cancellation attempt for 0x985700
cancellation result: Success
cancellation attempt for 0x985a90
cancellation result: Success
cancellation attempt for 0x985bb0
cancellation result: Success
cancellation attempt for 0x985cd0
cancellation result: Success
cancellation attempt for 0x985e80
cancellation result: Success
cancelled at Sat Oct 26 22:59:22 2019

(我不得不按ctrl+c键来停止程序)。

但是,如果我使用sock->async_connect(...) (上面代码中的注释部分),一切都很好,即

代码语言:javascript
复制
starting                                                                                                                                                                                      
on_resolve 0x6d6000 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d64c0 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6600 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6730 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6830 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6700 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6a90 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6bb0 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6cd0 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
on_resolve 0x6d6e80 Success, at Sat Oct 26 22:59:03 2019                                                                                                                                      
cancellation attempt for 0x6d6000                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d64c0                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6600                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6730                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6830                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6700                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6a90                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6bb0                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6cd0                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancellation attempt for 0x6d6e80                                                                                                                                                             
cancellation result: Success                                                                                                                                                                  
cancelled at Sat Oct 26 22:59:03 2019                                                                                                                                                         
on_connect 0x6d6000 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d64c0 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6600 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6730 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6830 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6700 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6a90 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6bb0 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6cd0 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
on_connect 0x6d6e80 Operation canceled, at Sat Oct 26 22:59:03 2019                                                                                                                           
finished                                                                                                                                                                                      

为什么会这样呢?我看过文档,没有发现任何提示,我做错了什么。

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-10-26 21:29:26

正如文档中所解释的那样,asio::async_connect

..。试图将套接字连接到一系列端点之一.对序列中的每个端点进行一次访问,直到成功建立连接为止。

如果提供了多个端点,则取消一个未完成的连接尝试将导致asio::async_connect从随后的端点(下面是 the循环)重试。

取消套接字后,尝试将其close。这将阻止asio::async_connect重新尝试。

代码语言:javascript
复制
        sock->cancel(ec);
        sock->close(ec);
票数 3
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/58574290

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档