调用 executor_work_guard：：reset 后io

问：

我是提升 asio 的新手，并在调用 work_gaurd 重置函数后尝试获得干净的退出。以下是我试图让它工作的代码。但是，我无法打印“IO Context Stopped”

我在这里错过了什么吗？

int main() {
  boost::asio::io_context ioContext;                                                                                                                                                                                                                       
  auto work = boost::asio::make_work_guard(ioContext);                                                                                                                                                                                                     
  ioContext.post([]() {                                                                                                                                                                                                                                    
    std::cout << "Task executed on thread: " << std::this_thread::get_id()                                                                                                                                                                                 
              << std::endl;                                                                                                                                                                                                                                
  });                                                                                                                                                                                                                                                      
  std::thread ioThread([&ioContext]() { ioContext.run(); });                                                                                                                                                                                               
  std::this_thread::sleep_for(std::chrono::seconds(2));                                                                                                                                                                                                    
  work.reset();                                                                                                                                                                                                                                            
  //! ioContext.stop();                                                                                                                                                                                                                                    
  ioThread.join();                                                                                                                                                                                                                                         
  std::cout << "IO context stopped." << std::endl;                                                                                                                                                                                                         
  return 0;                                                                                                                                                                                                                                                
}

C++ Boost boost-ASIO 共享 PTR

#include <boost/asio.hpp>
#include <iostream>
using namespace std::chrono_literals;

int main() {
    boost::asio::io_context ioContext;

    auto work = make_work_guard(ioContext);
    post(ioContext, [] { std::cout << "Task executed on thread" << std::endl; });

    std::thread ioThread([&] { ioContext.run(); });

    std::this_thread::sleep_for(2s);
    work.reset();

    ioThread.join();
    std::cout << "IO context stopped." << std::endl;
}

测试对象

g++ -std=c++20 -O2 -Wall -pedantic -pthread main.cpp && time ./a.out

印刷品，例如

Task executed on thread
IO context stopped.

real    0m2,004s
user    0m0,000s
sys     0m0,004s

奖金

请注意，没有防护装置的结果是一样的。更简单的是使用，这意味着一个工作卫士：thread_pool

在 Coliru 上直播

int main() {
    {
        boost::asio::thread_pool ioContext(1);
        post(ioContext, [] { std::cout << "Task executed on thread" << std::endl; });
        std::this_thread::sleep_for(2s);
        // ioContext.join();
    }

    std::cout << "IO context stopped." << std::endl;
}

调用 executor_work_guard：：reset 后io_service不停止

io_service not stopping after calling executor_work_guard::reset

评论

奖金

评论