【发布时间】:2012-04-12 20:45:38
【问题描述】:
当我尝试获取(未设置!)当前到期时间时 boost expires_from_now() 似乎实际上取消了计时器, 但它实际上按预期运行,但最终没有调用处理程序。
或者换句话说,当使用 expires_from_now() 访问一个截止时间定时器时 它会立即调用handler,过期不调用handler。
请考虑以下代码和相应的输出:
#include <boost/asio.hpp>
#include <boost/thread.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/date_time/posix_time/posix_time_io.hpp>
#include <iostream>
using namespace boost::posix_time;
using namespace std;
void handler1(const boost::system::error_code &ec)
{
if (ec == boost::asio::error::operation_aborted)
{
std::cout << microsec_clock::local_time() << " Handler1: Timer 1 was cancelled or retriggered." << std::endl;
}
else
{
std::cout << microsec_clock::local_time() << " Handler1: expired." << std::endl;
}
}
boost::asio::io_service io_service1;
class Mytimer {
public:
Mytimer();
void startTimer();
void runTimerThread();
bool isRunning();
private:
bool m_isRunning;
boost::asio::deadline_timer* m_pTimer;
boost::thread* m_pThread;
};
Mytimer::Mytimer()
: m_pTimer(NULL),
m_pThread(NULL)
{
m_pTimer = new boost::asio::deadline_timer(io_service1);
m_pTimer->async_wait(handler1);
}
void Mytimer::runTimerThread()
{
io_service1.run();
}
void Mytimer::startTimer()
{
m_pThread = new boost::thread(&Mytimer::runTimerThread, this);
m_pTimer->expires_from_now(boost::posix_time::seconds(10));
}
bool Mytimer::isRunning()
{
time_duration td = m_pTimer->expires_from_now();
if (td.total_seconds() > 0)
{
return true;
}
return false;
}
int main()
{
time_facet *facet = new time_facet("%Y%m%d %H:%M:%S%f");
std::cout.imbue(std::locale(std::cout.getloc(), facet));
cout << microsec_clock::local_time() << " before timer construction" << endl;
Mytimer timer;
cout << microsec_clock::local_time() << " before startTimer()" << endl;
timer.startTimer();
cout << microsec_clock::local_time() << " IsRunning: " << timer.isRunning() << endl;
for (int i = 0; i <= 20; i++)
{
sleep(1);
cout << microsec_clock::local_time() << " IsRunning: " << timer.isRunning() << endl;
}
}
20120412 22:41:45689235 计时器构造前
20120412 22:41:45689514 之前 startTimer()
20120412 22:41:45689619 正在运行:1
20120412 22:41:45689693 Handler1:定时器 1 被取消或重新触发。
20120412 22:41:46689792 正在运行:1
20120412 22:41:47689994 正在运行:1
20120412 22:41:48690179 正在运行:1
20120412 22:41:49690375 正在运行:1
20120412 22:41:50690530 正在运行:1
20120412 22:41:51690712 正在运行:1
20120412 22:41:52690884 正在运行:1
20120412 22:41:53691069 正在运行:1
20120412 22:41:54691236 正在运行:0
20120412 22:41:55691428 正在运行:0
20120412 22:41:56691614 正在运行:0
20120412 22:41:57691810 正在运行:0
20120412 22:41:58692001 正在运行:0
20120412 22:41:59692193 正在运行:0
20120412 22:42:00692364 正在运行:0
20120412 22:42:01692542 正在运行:0
20120412 22:42:02692706 正在运行:0
20120412 22:42:03692886 正在运行:0
20120412 22:42:04693071 正在运行:0
20120412 22:42:05693267 正在运行:0
20120412 22:42:06693465 正在运行:0
【问题讨论】:
-
我认为这里有两个问题:首先在构造函数中调用了定时器,没有任何过期时间,所以它实际上会立即过期。其次,当成员函数重新启动计时器时,没有处理程序。所以 expires_from_now 仍然有效(你可以看到 1 在 10 秒后变为 0),但永远不会调用处理程序,因为没有关联。
-
我暂时保留这个问题,也许有人可以证实我的结论。
-
您的代码 sn-p 非常臃肿并且充满了许多与问题无关和/或使其更难阅读的垃圾:stackoverflow.com/help/minimal-reproducible-example。
标签: c++ linux boost boost-asio