Opened 4 years ago
#13570 new Bugs
asio_handler_invoke resume wrong thread in coroutine
Reported by: | Owned by: | chris_kohlhoff | |
---|---|---|---|
Milestone: | To Be Determined | Component: | asio |
Version: | Boost 1.67.0 | Severity: | Problem |
Keywords: | asio, coroutine, asio_handler_invoke | Cc: |
Description
Environment:
Windows 10, VS2015 Update3, Boost 1.65.1, Boost 1.67.0, x86/x64
Coroutine should be suspended and resumed by the same thread, but in boost 1.67.0 it doesn't. I guess it's a bug introduced since boost 1.66.
In Boost 1.65.0, correct behavior, output:
thread : 37c0
thread : 37c0
hello
In Boost 1.67.0, wrong behavior, output:
thread : df4
thread : 1844
hello
#include <iostream> #include <boost/asio.hpp> #include <boost/asio/spawn.hpp> #include <boost/bind.hpp> #include <boost/thread.hpp> std::string Test(boost::asio::io_service& ios, boost::asio::yield_context yield) { boost::asio::io_service::work work(ios); #if BOOST_VERSION >= 106600 boost::asio::async_completion< boost::asio::yield_context, void(boost::system::error_code, std::string)> init(BOOST_ASIO_MOVE_CAST(boost::asio::yield_context)(yield)); auto handler = init.completion_handler; #else boost::asio::detail::async_result_init< boost::asio::yield_context, void(boost::system::error_code, std::string)> init(BOOST_ASIO_MOVE_CAST(boost::asio::yield_context)(yield)); auto handler = init.handler; #endif boost::thread t([&handler]() { boost::this_thread::sleep_for(boost::chrono::seconds(2)); boost::asio::detail::asio_handler_invoke( boost::bind<void>( handler, boost::system::error_code(), "hello"), &handler); }); t.detach(); return init.result.get(); } int main(int argc, char* argv[]) { boost::asio::io_service ios; boost::asio::spawn(ios, [&ios](boost::asio::yield_context yield) { boost::system::error_code ec; std::cout << "thread : " << boost::this_thread::get_id() << std::endl; std::string msg = Test(ios, yield[ec]); std::cout << "thread : " << boost::this_thread::get_id() << std::endl; std::cout << msg << std::endl; }); ios.run(); std::string tmp; std::cin >> tmp; return 0; }
Note:
See TracTickets
for help on using tickets.