如何用异步库实现忙信号

How to implement busy signal with async library?

本文关键字:信号 实现 何用 异步      更新时间:2023-10-16

我正在使用Boost.Asio,但这个问题应该涵盖任何异步框架。

我有一个通过网络发送和接收数据的类。我想给我的用户提供读写方法和is_busy(),让他们检查数据何时可用。现在,我让write方法的完成处理程序启动一个后台线程,该线程读取并返回到一个future,而read()方法则从该future读取。当返回数据时,write方法将bool设置为true,read线程将其设置为false。

有更好的方法吗?如果我使用Asio正确理解它,我需要完成处理程序,但没有办法告诉我的用户数据还没有到达而不被阻止。

更新

代码示例:

void Socket::write(const vector<byte> input) {
busy_ = true;
read_buffer_.clear();
socket_->async_write_some(asio::buffer(input), [&](const std::error_code ec, const size_t length) {
if (ec && ec != asio::error::operation_aborted) {
throw std::system_error(ec);
}
if (ec == asio::error::operation_aborted) {
return;
}
read_f = std::async(std::launch::async, [&]() {
socket_->async_read_some(asio::null_buffers(), [&](const std::error_code ec, const size_t length) {
if (ec && ec != asio::error::operation_aborted) {
throw std::system_error(ec);
}
if (ec == asio::error::operation_aborted) {
return;
}
read_buffer_.resize(socket_->available());
socket_->read_some(asio::buffer(read_buffer_));
busy_ = false;
});
unsigned long a = service_.run();
service_.reset();
busy_ = false;
return a;
});
});

我通过使用asio::socket_base::bytes_readable来检查套接字中是否有数据可供读取,并且如果字节数为0,我只会休眠一定数量的微秒。