C++ - Boost Thread/Bind/Shared_ptr：断言错误

Question

我有一个小问题无法解决。我正在制作一个小型服务器来将我的系统日志消息重定向到它。这是非常基本的，但我想知道我做错了什么，因为当我调用 join () 时，我一直出现以下错误：

/boost/path/shared_ptr.hpp:418: T* boost::shared_ptr< <template-parameter-1-1> >::operator->() const [with T = boost::thread]: Assertion `px != 0' failed.

代码将解释更多：

class SysLogServer
{
public:

  typedef boost::shared_ptr<boost::thread>  Ptr_thread;

  bool Start ()
  {
    ...
    _thrd = Ptr_thread(new boost::thread (boost::bind(&SysLogServer::run, this)));
    if (!_thrd.get ())
      return ERROR ("Thread couldn't be instanciated.");
    ...
  }

  bool Stop ()
  {
    ...
    _thrd->join ();
    ...
  }

private:

  void run()
  {
    ...
  }

  Ptr_thread _thrd;

};

非常感谢您的帮助。

PS：如果有任何改进可以更加“线程安全”，请告诉我，因为它真的让我感兴趣:)

编辑：

谢谢您的评论，我认为 shared_ptr 在那里确实没用，但是从 boost::enable_shared_from_this 继承该类可能很有用，以确保该类在线程结束之前不会被释放，而这种情况不应该发生。

Start() 当然是在 Stop() 之前调用的，我使用 state 属性执行简单的检查。 run() 方法只是接受连接。

class SysLogServer
{
public:

  bool Start ()
  {
    ...
    _thrd = boost::thread(boost::bind(&SysLogServer::run, this)));
    ...
  }

  bool Stop ()
  {
    ...
    _thrd.join();
    ...
  }

  void run ()
  {
    std::cout << "Start running..." << std::endl; // never printed
    // Create a socket
    // Create a sockaddr_in
    // Bind them together
    while (!_serverStopped && !listen(sockfd, 5)) // on Stop(): _severStopped = true
     {
       // Get socket from accept
       // Print the received data
       // Close the socket given by accept
     }
    // close the first socket
  }

  boost::thread _thrd;
};

现在可以了。我之前使用指针几乎相同的解决方案，但没有成功，我的朋友 SIGSEGV :)

编辑 2：

它不适用于指针，因为我忘记检查服务器有的 Stop()已开始。 Start() 方法因另一个原因而失败。

感谢您的有用建议

Answer 1

从您在此处提供的代码中无法立即清楚断言的原因，但尽管如此，该代码可以得到显着改进。

您似乎正在使用 shared_ptr，但似乎没有任何需要。 Ptr_thread 可以更改为 boost::thread。这将导致代码更简单、更高效，并且更容易理解对象的生命周期。

然后，代码可以更改为：

class SysLogServer
{
public:

  bool Start ()
  {
      ...
      _thrd = boost::thread(boost::bind(&SysLogServer::run, this)));
      ...
  }

  bool Stop ()
  {
      ...
      _thrd.join();
      ...
  }

private:

    void run()
    {
        ...
    }

    boost::thread _thrd;

};

如果在调用 Start() 之前调用 Stop()，则此代码仍然不正确，这是对原始代码的唯一明显解释代码失败。