在处理程序中重置 boost::deadline_timer 导致崩溃

Question

以下是我在服务器中使用的计时器的示例代码。它是一个处理大量数据的多线程进程。一旦定时器触发，它就会对处理过的数据进行一些操作，并在新的时间自行重置

class MyTimer
{
    public:
        MyTimer(boost::asio::io_service& ios):strand_(ios)
        {
            for (int i = 0; i < 10; i++)
            {
                std::auto_ptr<boost::thread> thread(
                        new boost::thread(boost::bind(&boost::asio::io_service::run,
                                          &ios_)));
                thread_pool_.push_back(thread.get());
                thread.release();
            }
            boost::posix_time::seconds expTime(10);
            eodTimer_.reset(new boost::asio::deadline_timer(ios));
            eodTimer_->expires_from_now(expTime);
            eodTimer_->async_wait(boost::bind(&MyTimer::onTimer, this));
        };

         ~MyTimer()
         {
              ThreadPool::iterator it(thread_pool_.begin());
              for (; it != thread_pool_.end(); ++it)
              {
                   (*it)->join();
                   delete *it;
               }
         }
        void onTimer()
        {
            //do some stuff...
            // reset timer
            boost::posix_time::seconds expTime(10);
            eodTimer_->expires_from_now(expTime);
            eodTimer_->async_wait(boost::bind(&MyTimer::onTimer, this));
        }

    private:
        boost::asio::io_service ios;
        boost::asio::strand strand_;
        boost::scoped_ptr<boost::asio::deadline_timer> eodTimer_;
};

到目前为止，我没有看到此代码有任何问题。但是在运行几个小时后，我的服务器崩溃了。堆栈跟踪将我指向 ::onTimer 回调处理程序。

#0  0x0a446c06 in boost::asio::detail::timer_queue<boost::asio::time_traits<boost::posix_time::ptime> >::cancel_timer (this=0xe3be0bc,
    timer_token=0xe9877ec) at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/detail/timer_queue.hpp:141
#1  0x0a445791 in boost::asio::detail::epoll_reactor<false>::cancel_timer<boost::asio::time_traits<boost::posix_time::ptime> > (this=0xe49f498,
        timer_queue=..., token=0xe9877ec) at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/detail/epoll_reactor.hpp:424
#2  0x0a444197 in boost::asio::detail::deadline_timer_service<boost::asio::time_traits<boost::posix_time::ptime>, boost::asio::detail::               epoll_reactor<false> >::cancel (this=0xe3be0a8, impl=..., ec=...) at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/detail/deadline_timer_service.hpp:104    #3  0x0a443f31 in boost::asio::detail::deadline_timer_service<boost::asio::time_traits<boost::posix_time::ptime>, boost::asio::detail::               epoll_reactor<false> >::expires_at (this=0xe3be0a8, impl=..., expiry_time=..., ec=...)
            at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/detail/deadline_timer_service.hpp:120
#4  0x0a441e92 in boost::asio::detail::deadline_timer_service<boost::asio::time_traits<boost::posix_time::ptime>, boost::asio::detail::               epoll_reactor<false> >::expires_from_now (this=0xe3be0a8, impl=..., expiry_time=..., ec=...)
                at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/detail/deadline_timer_service.hpp:137
#5  0x0a43f895 in boost::asio::deadline_timer_service<boost::posix_time::ptime, boost::asio::time_traits<boost::posix_time::ptime> >::                expires_from_now (
                    this=0xe49f438, impl=..., expiry_time=..., ec=...) at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/deadline_timer_service.hpp: 144
#6  0x0a451d64 in boost::asio::basic_deadline_timer<boost::posix_time::ptime, boost::asio::time_traits<boost::posix_time::ptime>, boost::asio::       deadline_timer_service<boost::posix_time::ptime, boost::asio::time_traits<boost::posix_time::ptime> > >::expires_from_now (this=0xe9877e8, expiry_time=...)
                        at /vobs/FO_FOX/fo_fx_appl/appl/include/boost/asio/basic_deadline_timer.hpp:297
#7  0x0a44e941 in fxpay::AggregatorRouter::Impl::MyTimer::onTimer (this=0xe987e48) at MyTimer.cpp:183

我使用 boost::dead_line 计时器的方式有问题吗？ （我用的是1.39 boost版本）

Answer 1

您正在运行 10 个线程，并且没有同步访问 eodTimer。

deadline_timer 对象不是线程安全的，因此您会因为数据竞争而获得未定义行为。

您的意思是在链上运行计时器吗？