asio::io_context的事件循环

曾经终败给现在 2023-06-23 13:20 6阅读 0赞

### 1. asio::io\_context ###

asio::io\_context表示io的上下文，任何io都会涉及到一个io\_context。

同步io会隐式地启动一个io\_context, 而异步io需要我们指定一个io\_context。

调用run()函数进入io事件循环。如果有io事件，事件完成会调用回调函数;  如果没有io事件, io\_context会自动取消事件循环。

int main()
    {  
        asio::io_context ioc;
        asio::ip::tcp::endpoint ep(asio::ip::address::from_string("127.0.0.1"), 6768);
        asio::ip::tcp::socket sock(ioc, ep.protocol());
        asio::ip::tcp::socket sock1(ioc, ep.protocol());
    
        sock.async_connect(ep, [](const std::error_code & err) {
            if (err.value() != 0) {
                std::cout << "Error: "<< err.message() << std::endl;
            }
        });
       
        sock1.async_connect(ep, [](const std::error_code & err) {
            if (err.value() != 0) {
                std::cout << "Error: "<< err.message() << std::endl;
            }
        });
        ioc.run();
       
        getchar();
        return 0;
    }

执行结果：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeWF6aGVuMjAxMQ_size_16_color_FFFFFF_t_70][]

调整语句ioc.run()的位置，置于两个async\_connect()之间。

sock.async_connect(ep, [](const std::error_code & err) {
        if (err.value() != 0) {
            std::cout << "Error: "<< err.message() << std::endl;
        }
    });
    ioc.run();
    
    // 这个回调函数不会执行了, 因为run的事件循环已经结束了
    sock1.async_connect(ep, [](const std::error_code & err) {
        if (err.value() != 0) {
            std::cout << "Error: "<< err.message() << std::endl;
        }
    });

执行结果:

![20191219153204359.png][]

###  2.asio::io\_context::work   ###

有时候, 我们希望调用run()后，即使没有`io`事件, 也不会退出事件循环, 而是一直等待, 当有了新的异步io调用的时候, 还可以继续使用该循环。 `asio::io_context::work`可以防止`io_context`在没有io事件的情退出。

int main()
    {  
        asio::io_context ioc;
        asio::ip::tcp::endpoint ep(asio::ip::address::from_string("127.0.0.1"), 6768);
        asio::ip::tcp::socket sock(ioc, ep.protocol());
        asio::ip::tcp::socket sock1(ioc, ep.protocol());
    
        asio::io_context::work worker(ioc);
        std::thread t([&ioc]() {ioc.run(); });
       
        sock.async_connect(ep, [](const std::error_code & err) {
            if (err.value() != 0) {
                std::cout << "Error: " << err.message() << std::endl;
            }
        });
        
        sock1.async_connect(ep, [](const std::error_code & err) {
            if (err.value() != 0) {
                std::cout <<"Error: "<< err.message() << std::endl;
            }
        });
       
        std::cout << "Main thread will for 3 seconds...\n";  // 防止stop()执行过快
        std::this_thread::sleep_for(std::chrono::seconds(3));
        std::cout << "Main thread weak up...\n";
        ioc.stop();  // 显式停止io_context, 否则无法终止
        t.join();
    
        return 0;
    }

执行结果：

![20191219154208517.png][]

注释掉语句asio::io\_context::work worker(ioc)后。

执行结果：

![20191219154440387.png][]

即事件循环在没有IO事件的情况下, 就自动结束了。

### 3.总结 ###

在不确定io异步事件回调发生的情况下, 如果想要`io_context`事件循环一直进行, 就要使用`io_context::work对象`来执行。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeWF6aGVuMjAxMQ_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191219152715114.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xpeWF6aGVuMjAxMQ==,size_16,color_FFFFFF,t_70
[20191219153204359.png]: https://img-blog.csdnimg.cn/20191219153204359.png
[20191219154208517.png]: https://img-blog.csdnimg.cn/20191219154208517.png
[20191219154440387.png]: https://img-blog.csdnimg.cn/20191219154440387.png