c++ - 使用 use_future 提升 Asio async_recieve_from 多播不能与 async_send_to 同时工作
问题描述
ITNOA
我想编写同时发送和接收多播的程序,如下所示
int main()
{
const string group_address = "235.127.1.1";
constexpr uint16_t PORT_NUMBER = 8765;
boost::asio::io_context io_context;
auto work_guard = boost::asio::make_work_guard(io_context);
BoostMessageSender message_sender(group_address, "eth1", PORT_NUMBER, io_context);
BoostMessageReceiver message_receiver(group_address, "eth1", PORT_NUMBER, io_context);
std::thread t1([&io_context]()
{
cout << __LINE__ << endl;
io_context.run();
});
this_thread::sleep_for(1s);
std::array<char, 20> data = {};
auto result = std::async(std::launch::async, [&message_receiver, &data]()
{
message_receiver.receive(gw::buffer(data));
cout << " receive finished" << endl; // does not reach this line :(((
});
this_thread::sleep_for(1s);
message_sender.send("Any body there!");
result.wait(); // Raise exception what(): std::future_error: No associated state
cout << "receive message: ";
std::copy(std::begin(data),
std::end(data),
std::ostream_iterator<char>(std::cout, ""));
io_context.stop();
t1.join();
return 0;
}
我的问题是为什么 result.wait() 会引发异常?
可能重要的一点是,当我删除message_sender.send
行时,该程序result.wait()
直到结束才会引发任何异常和块行。但是当message_sender.send
添加行时,该程序引发异常并且无法正常工作。
我的 message_sender 等于此代码。
我的 message_receiver 如下所示
BoostMessageReceiver::BoostMessageReceiver(const std::string& group_address, const std::string& interface_name, uint16_t port_number, ba::io_context& io_context)
: AbstractMessageReceiver(group_address, interface_name, port_number)
, io_context(io_context)
, listen_endpoint(ba::ip::address_v4::any(), port_number)
, socket(io_context)
{
socket.open(listen_endpoint.protocol());
socket.set_option(ba::ip::udp::socket::reuse_address(true));
socket.bind(listen_endpoint);
// Join to multicast group
socket.set_option(ba::ip::multicast::enable_loopback(true));
socket.set_option(ba::ip::multicast::join_group(ba::ip::address::from_string(group_address)));
}
std::pair<bool, std::size_t> BoostMessageReceiver::receive(const AbstractMessageReceiver::MutableBuffer& buffer) noexcept
{
ba::ip::udp::endpoint sender_endpoint;
std::future<std::size_t> result = socket.async_receive_from(ba::buffer(buffer.data(), buffer.size()), sender_endpoint, ba::use_future);
return std::make_pair(result.get() != 0, result.get());
}
我哪里错了?
我在以下平台上测试这些代码
Visual Studio 2019 16.7.4
Windows 10 1909 latest update
Boost 1.73.0
Ubuntu 20.04.1 LTS
GCC 9.3.0
Boost 1.71.0
解决方案
你得到了no_state
因为get
onfuture
只能被调用一次。
以下
std::make_pair(result.get() != 0, result.get());
get
被调用两次。
见参考:
注意 鼓励实现在调用前检测 valid() 为假的情况,并抛出 std::future_error 错误条件为 std::future_errc::no_state。
在第一次调用 后get
,valid
返回false
。
推荐阅读
- c++ - 当我有两个指针在同一个内存时,为什么我必须调用两次“删除”?
- java - 在房间版本 1.1.1 中创建复合主键时无法使用 Kotlin 编译器构建 android studio 项目
- javascript - 在没有只读错误的情况下无法访问深层嵌套对象属性
- python - 如何在 python 中使用 requests.get 获取数据之前等待页面加载,而不使用 api
- java - Repaint() 方法不会一一调用paint() 和paintComponent() 方法,只有paintComponent() 方法有效
- unity3d - 你可以在 Unity 中导出切片精灵(PNG 图像)吗?
- php - php 日期比较
- pseudocode - 如何编写伪代码
- codeigniter - localhost 当前无法处理此请求。代码点火器问题
- jsf - 通过 ajax 调用使用模式“MMMM yyyy”更新组件 primefaces datepicker 会导致“位置 [...] 处未捕获的名称”异常