负载测试中 __pthread_mutex_cond_lock_full 的断言失败

Question

我使用以下代码在我在 debian 8 上运行的 c++ 应用程序中创建了一个计时器对象。

class Timer
{
private:
    std::condition_variable cond_;
    std::mutex mutex_;
    int duration;
    void *params;

public:
    Timer::Timer(void (*func)(void*))
    {
      this->handler = func;
      this->duration = 0;
      this->params = NULL;
    };

    Timer::~Timer(){};

    void Timer::start(int duree, void* handlerParams)
    {
      this->duration = duree;
      this->params   = handlerParams;
      /*
       * Launch the timer thread and wait it
       */
      std::thread([this]{
                std::unique_lock<std::mutex> mlock(mutex_);
                std::cv_status ret = cond_.wait_for(mlock, 
                                     std::chrono::seconds(duration));
                if ( ret ==  std::cv_status::timeout )  
                {
                    handler(params);
                }
              }).detach();

      };

      void Timer::stop()
      {
          cond_.notify_all();
      }
    };

它在 gdb 和正常条件下都能正常工作，但在 30 个或更多请求的负载测试中，它会因断言而崩溃：

nptl/pthread_mutex_lock.c:350: __pthread_mutex_cond_lock_full: 断言`(-(e)) != 3 || !robust'失败了。

我不明白这个断言的原因。任何人都可以帮助我吗？ 谢谢你

Answer 1

基本上你有一个访问定时器对象的分离线程，所以很可能你销毁了定时器对象但线程仍在运行并访问它的成员（互斥体，条件变量）。

断言本身从 glibc 源代码中说，互斥锁的所有者已经死亡。

Answer 2

非常感谢您的 cmets ！我将尝试更改线程分离，并进行负载测试。 这是我的问题的 MVCE，它是大型应用程序的一部分。

/**
 * \file Timer.hxx
 * \brief Definition of Timer class.
 */
  #include <chrono>
  #include <thread>
  #include <mutex>
  #include <condition_variable>

    class Timer
    {
    private:
    std::condition_variable cond_;
    std::mutex mutex_;
    int duration;
    void *params;

    public:
    Timer(void (*func)(void*));
    ~Timer();

    void (*handler)(void*);
    void start(int duree, void* handlerParams);
    void stop();
    };

 /*
 * Timer.cxx
 */
 #include "Timer.hxx"
 Timer::Timer(void (*func)(void*))
{
//this->set_handler(func, params);
this->handler = func;
this->duration = 0;
this->params = NULL;
}

Timer::~Timer()
{
}

void Timer::start(int duree, void* handlerParams)
{
this->duration = duree;
this->params   = handlerParams;
/*
 * Launch the timer thread and wait it
 */
std::thread([this]{
                std::unique_lock<std::mutex> mlock(mutex_);
                std::cv_status ret = cond_.wait_for(mlock, std::chrono::seconds(duration));
                if ( ret ==  std::cv_status::timeout )  
                {
                    handler(params);
                }
              }).detach();

   }


 void Timer::stop()
 {
  cond_.notify_all();
 }

/*
 * MAIN
 */
#include <stdio.h>
#include <iostream>
#include <unistd.h>
#include "Timer.hxx"

using namespace std;

void timeoutHandler(void* params)
{
char* data= (char*)params;
cout << "Timeout triggered !! Received data is: " ;
if (data!=NULL)
    cout << data << endl;   
}

int main(int argc, char **argv)
{
int delay=5;
char data[20] ="This is a test" ;

Timer *t= new Timer(&timeoutHandler) ;
t->start(delay, data);
cout << "Timer started !! " << endl;    
sleep(1000);
t->stop();
delete t;
cout << "Timer deleted !! " << endl;    

return 0;
}