使用boost::thread::interrupt()跨模块中断阻塞代码引发崩溃求助

问题场景 #

在使用Boost线程初始化ActiveMQ时，调用inst.reset()（代码中的Line 2）会导致程序崩溃，省略该行则产生内存泄漏；但将ActiveMQ的初始化代码（Line 1）替换为模块内阻塞代码（如for(;;){}）时，线程能正常中断且不崩溃。疑问：是否不允许跨模块使用Boost线程函数？该如何解决？

相关代码 #

Base类init方法

bool Base::init()
{
    boost::thread th(boost::bind(&Derived::init_derived, this));
    if(!th.timed_join(boost::posix_time::seconds(10))) {
        th.interrupt();
        return false;
    }
    return true;
}

Derived子类init_derived方法

void Derived::init_derived()
{
    try
    {
        m_session = connection.createSession(cms::Session::AUTO_ACKNOWLEDGE);  // Line 1
    }
    catch(boost::thread_interrupted const&)
    {
        // log error...
    }
}

Base类create模板方法

template <typename Derived>
boost::shared_ptr<Derived> Base::create(Derived *obj)
{
    boost::shared_ptr<Derived> inst(obj);
    if(inst != nullptr && !inst->init()) {
        inst.reset();  // Line 2
    }
    return inst;
}

问题分析 #

不是跨模块不能使用Boost线程，而是线程中断时的资源清理时机错误导致崩溃，具体原因如下：

1. Boost线程的中断机制依赖线程内部主动检查中断点（比如Boost自带的阻塞函数会响应中断），但第三方库（如ActiveMQ）的阻塞函数（createSession）不会主动处理Boost的线程中断标记。
2. 当init()超时调用th.interrupt()后，子线程仍卡在createSession的跨模块调用中，既没有返回，也无法进入catch(boost::thread_interrupted)分支。
3. 主线程在init()返回false后，调用inst.reset()销毁了Derived对象，但子线程此时仍持有指向该对象的this指针；后续子线程从createSession返回后，会访问已析构对象的成员（如m_session），触发野指针访问崩溃。

解决方案 #

• 等待线程完全退出后再销毁对象
  修改init()方法，在调用th.interrupt()后额外等待一段时间，确保子线程完全终止，不再访问this指针：

  bool Base::init()
  {
      boost::thread th(boost::bind(&Derived::init_derived, this));
      if(!th.timed_join(boost::posix_time::seconds(10))) {
          th.interrupt();
          // 额外等待线程退出，避免子线程未结束就销毁对象
          th.timed_join(boost::posix_time::seconds(2));
          return false;
      }
      return true;
  }
  

• 绑定对象生命周期与线程生命周期
  通过boost::shared_ptr传递对象给子线程，延长对象的生命周期直到线程结束，避免主线程提前销毁对象：

  // 注意：Base类需继承boost::enable_shared_from_this<Base>
  bool Base::init()
  {
      boost::shared_ptr<Derived> self = boost::static_pointer_cast<Derived>(shared_from_this());
      boost::thread th([self]() {
          self->init_derived();
      });
      if(!th.timed_join(boost::posix_time::seconds(10))) {
          th.interrupt();
          th.timed_join(boost::posix_time::seconds(2));
          return false;
      }
      return true;
  }
  

• 使用第三方库自带的超时机制
  如果ActiveMQ的createSession支持超时参数，直接使用其自带的超时功能，替代Boost线程中断，确保子线程能正常返回并清理资源：

  // 示例：假设createSession支持超时参数（需参考ActiveMQ官方文档）
  m_session = connection.createSession(cms::Session::AUTO_ACKNOWLEDGE, 10000); // 10秒超时
  

• 插入中断检查点（仅适用于可中断场景）
  在第三方阻塞调用前后插入Boost的中断检查点，让子线程能及时响应中断，但该方法仅在createSession中间有机会触发检查时有效：

  void Derived::init_derived()
  {
      try
      {
          boost::this_thread::interruption_point(); // 插入中断检查点
          m_session = connection.createSession(cms::Session::AUTO_ACKNOWLEDGE);
          boost::this_thread::interruption_point();
      }
      catch(boost::thread_interrupted const&)
      {
          // log error...
      }
  }
  

内容的提问来源于stack exchange，提问作者user2338150