- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我有一个 tcp 客户端,它会在截止日期前轮询服务器以获得答案,这样如果无法访问服务器,客户端就不会被阻止。我遇到的问题是 async_wait
似乎从不调用它的处理程序,在连接失败时有效地阻塞了客户端。每次调用 tcpPoll
都会有自己的线程(这就是我创建新的 io_service
的原因),但即使没有多线程,它似乎也无法工作。此外,NetworkEntity
对象在其生命周期内可以多次调用 tcpPoll
。
我的问题是:什么阻止了 deadline_timer
调用它的处理程序? (以及如何解决)
这里是一些相关的代码,只要没有失败(连接、写入、读取),它就可以工作(如果有点长,抱歉):
void NetworkEntity::stop()
{
stopped_ = true;
//close socket
//cancel timeout
}
void NetworkEntity::check_timeout(const boost::system::error_code& error)
{
if (stopped_)
return;
if (timeout_.expires_at() <= boost::asio::deadline_timer::traits_type::now())
{
stop();
timeout_.expires_at(boost::posix_time::pos_infin);
std::cout << address_ << " timed out\n";
}
timeout_.async_wait(boost::bind(&NetworkEntity::check_timeout, this, boost::asio::placeholders::error));
}
std::vector<std::string> NetworkEntity::tcpPoll(const char* message, const char endOfMessage)
{
boost::asio::io_service io_service;
stopped_ = false;
timeout_.expires_from_now(boost::posix_time::seconds(TIMEOUT_));
timeout_.async_wait(boost::bind(&NetworkEntity::check_timeout, this, boost::asio::placeholders::error));
tcp::resolver resolver(io_service);
start_connect(&io_service, resolver.resolve(tcp::resolver::query(address_, port_)), message, endOfMessage);
io_service.run();
//retrieve answer from class
//return answer
}
void NetworkEntity::start_connect(boost::asio::io_service* io_service, tcp::resolver::iterator endpoint_iterator, const std::string message, const char endOfMessage)
{
socket_.reset(new tcp::socket(*io_service));
socket_->async_connect(endpoint_iterator->endpoint(),
boost::bind(&NetworkEntity::handle_connect, this, io_service, boost::asio::placeholders::error, endpoint_iterator, message, endOfMessage));
}
void NetworkEntity::handle_connect(boost::asio::io_service* io_service, const boost::system::error_code& err, tcp::resolver::iterator endpoint_iterator, const std::string message, const char endOfMessage)
{
if(stopped_)
return;
if (err)
{
std::cout << "Connect error: " << err.message() << "\n";
stop();
}
else
{
start_write(message, endOfMessage);
}
}
void NetworkEntity::start_write(const std::string message, const char endOfMessage)
{
std::ostream request_stream(&request_);
request_stream << message;
boost::asio::async_write(*socket_, request_,
boost::bind(&NetworkEntity::handle_write, this, boost::asio::placeholders::error, endOfMessage));
}
void NetworkEntity::handle_write(const boost::system::error_code& error, const char endOfMessage)
{
if (stopped_)
return;
if (!error)
{
//sleep for 500ms to let time for the reciever to process info (had a bug on this one)
start_read(endOfMessage);
}
else
{
std::cout << "write error : " << error.message() << "\n";
stop();
}
}
void NetworkEntity::start_read(const char endOfMessage)
{
boost::asio::async_read_until(*socket_, answer_, endOfMessage,
boost::bind(&NetworkEntity::handle_read, this, boost::asio::placeholders::error));
}
void NetworkEntity::handle_read(const boost::system::error_code& error)
{
if (stopped_)
return;
if (error)
{
std::cout << "read error : " << error.message() << "\n";
stop();
}
else
{
stop();
}
}
最佳答案
我认为您一定对 io_service 的多个实例感到困惑。
我认为这是因为在您的代码中您从未显示如何初始化timeout_
。而您用于连接的 io_service
实例仅在您的 tcpPoll
函数中实例化...这让我相信您不小心在一个单独的服务器上注册了截止时间计时器你甚至不运行的 io_service?
这是一个实际有效的版本,注意:
stopped_
bool 值,因为它是不必要的并且必然会造成混淆check_timeout
和 stop
的新实现,了解如何检测各种程序流#include <iostream>
#include <boost/asio.hpp>
#include <boost/bind.hpp>
using tcp = boost::asio::ip::tcp;
struct NetworkEntity {
boost::asio::io_service io_service;
boost::asio::deadline_timer timeout_{io_service};
std::string address_ = "localhost";
std::string port_ = "6767";
int TIMEOUT_ = 3;
boost::shared_ptr<tcp::socket> socket_;
boost::asio::streambuf request_, answer_;
void stop()
{
if (socket_)
{
socket_->cancel();
socket_->close();
}
timeout_.cancel();
io_service.stop();
}
void check_timeout(const boost::system::error_code& error)
{
if (error != boost::asio::error::operation_aborted)
{
stop();
std::cout << address_ << " timed out\n";
}
timeout_.async_wait(boost::bind(&NetworkEntity::check_timeout, this, boost::asio::placeholders::error));
}
std::vector<std::string> tcpPoll(const char* message, const char endOfMessage)
{
timeout_.expires_from_now(boost::posix_time::seconds(TIMEOUT_));
timeout_.async_wait(boost::bind(&NetworkEntity::check_timeout, this, boost::asio::placeholders::error));
tcp::resolver resolver(io_service);
start_connect(&io_service, resolver.resolve(tcp::resolver::query(address_, port_)), message, endOfMessage);
io_service.run();
//retrieve answer from class
//return answer
std::ostringstream oss;
oss << &answer_;
return { oss.str() };
}
void start_connect(boost::asio::io_service* io_service, tcp::resolver::iterator endpoint_iterator, const std::string message, const char endOfMessage)
{
socket_.reset(new tcp::socket(*io_service));
socket_->async_connect(endpoint_iterator->endpoint(),
boost::bind(&NetworkEntity::handle_connect, this, io_service, boost::asio::placeholders::error, endpoint_iterator, message, endOfMessage));
}
void handle_connect(boost::asio::io_service* io_service,
const boost::system::error_code& err,
tcp::resolver::iterator endpoint_iterator,
const std::string message,
const char endOfMessage)
{
if (err)
{
std::cout << "Connect error: " << err.message() << "\n";
stop();
}
else
{
start_write(message, endOfMessage);
}
}
void start_write(const std::string message, const char endOfMessage)
{
std::ostream request_stream(&request_);
request_stream << message;
boost::asio::async_write(*socket_, request_,
boost::bind(&NetworkEntity::handle_write, this, boost::asio::placeholders::error, endOfMessage));
}
void handle_write(const boost::system::error_code& error, const char endOfMessage)
{
if (!error)
{
//sleep for 500ms to let time for the reciever to process info (had a bug on this one)
start_read(endOfMessage);
}
else
{
std::cout << "write error : " << error.message() << "\n";
stop();
}
}
void start_read(const char endOfMessage)
{
boost::asio::async_read_until(*socket_, answer_, endOfMessage,
boost::bind(&NetworkEntity::handle_read, this, boost::asio::placeholders::error));
}
void handle_read(const boost::system::error_code& error)
{
if (error)
{
std::cout << "read error : " << error.message() << "\n";
}
stop();
}
};
int main()
{
NetworkEntity ne;
for (auto& s : ne.tcpPoll("this is my request", '\n'))
{
std::cout << "Line: '" << s << "'\n";
}
}
关于c++ - boost::asio::deadline_timer 不调用处理程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/24295101/
我正在研究基于 boost 1.52 的 boost::asio::deadline_timer 的实现。 如 the article on highscore 中所述,它分三部分实现: deadli
我需要在两个线程之间共享一个 boost::deadline_timer。 boost 文档说“共享实例不是线程安全的”。这是一个示例代码: ClassA : public enable_shared
我有点迷失在库的构造中,我必须将它们纠缠在一起。我需要帮助将一些计时器引入到这个结构中。 我有以下内容: com.cpp 具有 main 并包含 com.hpp com.hpp 包含一个 host.h
我已经为 boost::asio 实现了一个非常标准的阻塞 api 模拟和超时。这是我的主要周期: io_service io_svc; tcp::endpoint endpoint(tcp::v4(
我有一个这样的测试类。我想要做的是继续运行这个对象中的三个计时器。但是在我实例化一个对象之后,一些计时器会一直重复,但其他计时器会在 3 分钟后消失。谁能给我解释一下? class EventProc
调用 deadline_timer::wait 是否会导致 io_service 中的其他任务在等待时执行,或者如果在其中调用它是否会完全阻塞 io 线程? io_service service; i
我正在使用一个 boost deadline_timer,它似乎在拥有的对象被删除后调用它的处理程序。我已经尝试了几种方法来让它发挥作用。 首先,我只是通过绑定(bind)到处理程序和使用“share
在阅读了 boost::asio::deadline_timer 的文档之后,似乎 io_service::run() 和处理程序方法是在同一个线程上调用的。有什么方法可以在一个线程上创建一个计时器,
我很惊讶没有在 boost::asio(我们任何广泛使用的库)中找到时钟组件,所以它尝试制作一个简单、简约的实现来测试我的一些代码。 使用 boost::asio::deadline_timer 我制
当您在运行的计时器上调用 expires_from_now() 时,定时器被取消,并调用一个新的定时器。因此调用关联的处理程序。在处理程序中很容易区分在已取消和已过期的计时器之间。然而,我想知道,是否
我希望下面的代码打印 Hello, world!每 5 秒,但发生的情况是程序暂停 5 秒,然后一遍又一遍地打印消息,没有后续暂停。我错过了什么? #include #include #inclu
下面是一个用计时器包装线程的测试类的实现。奇怪的是,如果将截止日期设置为 500 毫秒,它会起作用,但如果我将它设置为 1000 毫秒,它就不会起作用。我做错了什么? #include "TestTi
我尝试在这个简单的测试应用程序中使用 boost deadline_timer,但遇到了一些麻烦。目标是使用 deadline_timer 的 expires_at() 成员函数让计时器每 45 毫秒
我正在使用多个 boost::asio::deadline_timer在一个 io_service 对象上。 std::shared_ptr的 boost::asio::deadline_timer存
我正在学习 Boost.Asio,但我对 boost::asio::deadline_timer async_wai 有疑问。这是来自 boost 主页的代码: // // timer.cpp //
我有一个 tcp 客户端,它会在截止日期前轮询服务器以获得答案,这样如果无法访问服务器,客户端就不会被阻止。我遇到的问题是 async_wait 似乎从不调用它的处理程序,在连接失败时有效地阻塞了客户
我能够为 boost deadline_time(它是一个成员)创建一个处理程序通过声明它是静态的。不幸的是,这会阻止访问非静态成员数据。 我有一系列超时。所以我的想法是有一个单一的 deadline
我使用 boost::asio::deadline_timer 来运行一个函数。我有如下 MosquitoInterface 类 class MosquitoInterface{ Mosquit
我想知道 boost::asio::deadline_timer 线程安全吗? 有人可以回答我吗? 最佳答案 您要查找的信息可以在documentation中找到. Thread Safety Dis
这个问题在这里已经有了答案: boost asio deadline_timer async_wait(N seconds) twice within N seconds cause operati
我是一名优秀的程序员,十分优秀!