执行时使用Boost::ASIO::deadline_timer时出错

Question

我试图使用以下代码实现一个基本的截止时间计时器:

          class Example
          {
              Example(boost::asio::io_service& ios, config& cfg)
                        : ios_(ios), cfg_(cfg), tcp_client_(ios) {
    
                state = new State();
                boost::asio::deadline_timer t(ios, boost::posix_time::seconds(5));
                t.async_wait(boost::bind(&bse_dummy_exchange::start_heartbeats,this,boost::asio::placeholders::error,boost::ref(t)));
              }
              ~Example() = default;
              void start_heartbeats(const boost::system::error_code& e,boost::asio::deadline_timer& t)
              {
                  std::cout << "Hello, world!\n";
                  t.expires_from_now(boost::posix_time::seconds(5));
     t.async_wait(boost::bind(&bse_dummy_exchange::start_heartbeats,this,boost::asio::placeholders::error,boost::ref(t)));
              }
          }

编译进行得很好，但是在执行过程中我得到了这个错误消息，我不明白，有人能帮我一下吗:

    Hello, world!
    bse_dummy_exchange: ../nptl/pthread_mutex_lock.c:425: 
    __pthread_mutex_lock_full: Assertion `INTERNAL_SYSCALL_ERRNO (e, __err) 
    != ESRCH || !robust' failed.
    Aborted (core dumped)

Answer 1

你没有显示互斥体-所以我们无法回答。

也就是说，关于异步，可能出错的所有事情都在出错:

>

您存在内存泄漏(state是拥有的指针成员，但您默认了析构函数？https://www.google.com/search?q=CPPreference+rule+of+three&ampoq=CPPreference+rule+of+three&ampaqs=chrome..69i57j69i64.2928j0j7&ampsourceID=chrome&ampie=UTF-8)

这是UB:

     boost::asio::deadline_timer t(ios, boost::posix_time::seconds(5));
     t.async_wait(boost::bind(&bse_dummy_exchange::start_heartbeats,this,boost::asio::placeholders::error,boost::ref(t)));

async_立即返回，但操作是异步运行的。 在您的示例中，T是一个局部变量，在构造函数返回后立即超出作用域。 所以，那是行不通的。

与start_heartbeats中的问题完全相同

（假设example实际上被命名为use_dummy_exchange)

至少，计时器的生存期需要超过ASYNC_WAIT的生存期。

当然，不修复与互斥错误相关的任何内容--这不包括在内:

住在科里鲁

#include <boost/asio.hpp>
#include <iostream>
struct config { };

struct TcpClient {
    TcpClient(boost::asio::io_service& ios) : ios_(ios){}
  private:
    boost::asio::io_service& ios_;
};

struct Example {
    struct State {};
    std::unique_ptr<State> state;

    Example(boost::asio::io_service& ios, config& cfg)
        : state(std::unique_ptr<State>()),
          ios_(ios),
          cfg_(cfg),
          tcp_client_(ios)
    {
        heartbeats();
    }

    void heartbeats(const boost::system::error_code& e = {}) {
        std::cout << "Hello, world!" << std::endl;
        if (!e) {
            t.expires_from_now(boost::posix_time::seconds(5));
            t.async_wait([this](auto ec) { heartbeats(ec); });
        }
    }

  private:
    boost::asio::io_service& ios_;
    config cfg_;
    TcpClient tcp_client_;
    boost::asio::deadline_timer t{ios_};
};

int main() {
    boost::asio::io_service ios;
    config cfg;
    Example ex(ios, cfg);

    ios.run_for(std::chrono::seconds(12));
}

打印

Hello, world!
Hello, world!
Hello, world!

它没有内存泄漏，在UBSAN/ASAN下运行干净