c++ - Linux 应用程序在 boost::thread::join 上卡住

Question

我目前正在将我们的 c++ qt 应用程序移植到在 MSVC 中开发的 linux 上，它在某些线程操作上一直卡住。在 Windows 中，一切正常。我们的线程实现使用以下代码(摘录):

thread.h:

class our_thread
{
    public:
        our_thread();
        ~our_thread();

        void run(boost::thread*);
        void join(const char* = 0);
        inline bool is_running() const;

    private:
        void delete_thread();

        bool thread_is_running;
        boost::thread* thread_object;
};

线程.cpp:

void our_thread::run(boost::thread* t)
{
    this->delete_thread();
    this->thread_object = t; 
    this->thread_is_running = true;
    QApplication::setOverrideCursor(Qt::BusyCursor);   
    plot("in run");
}

void our_thread::join(const char* text)
{
    plot("in join");
    if(this->thread_object == 0) { return; }
    this->thread_is_running = false;
    QApplication::restoreOverrideCursor();
    if(text)
    {
        plot(text);
    }
    progress.show(false);
    this->thread_object->join();
    this->delete_thread();
}

void our_thread::delete_thread()
{
    this->thread_is_running = false;
    delete this->thread_object;
    this->thread_object = 0;
}

调用例如:

this->do_something_thread.run(new boost::thread(&function_name, this, param1));
...
this->do_something_thread.join("Part creation finished");

plot() 调用是用户信息，但此处也用于调试输出。

现在，对于某些操作，此过程始终有效，对于某些操作，它总是在线程中的所有代码完成并调用 join() 后卡住应用程序。如果我调试软件并单步执行代码，它会奇迹般地完美运行，直到我再次尝试使用该线程。然后它直接卡住在 run() 调用上。

我试过 boost 1.39.0 和 1.49.0 没有任何区别。我们使用的是 RedHat 5.4，一切都是用 gcc44 编译的。

编辑:我想强调的是，在 Windows 上一切正常，所以我不认为这是一个简单的代码错误。更像是特定于 Linux 的事物，例如某些特定于编译器的设置或标志或任何可能产生此类错误的东西。

Answer 1

我不明白你为什么要使用复杂的手动内存管理和冗余 bool 标志(如果有一个线程，它必须加入， bool 是多余的和未使用的)。

但是，我也看不到出现死锁的空间。

这是一个独立的版本，显示它“有效” Live On Coliru

#include <boost/thread.hpp>

void plot(std::string msg)
{
    static boost::mutex mx;
    boost::lock_guard<boost::mutex> lk(mx);

    std::cout << msg << "\n";
}

class our_thread
{
    public:
        our_thread() : thread_object(0), thread_is_running(false) {}
        ~our_thread(){delete_thread();}

        void run(boost::thread*);
        void join(const char* = 0);
        inline bool is_running() const;

    private:
        void delete_thread();

        bool thread_is_running;
        boost::thread* thread_object;
};

void our_thread::run(boost::thread* t)
{
    this->delete_thread();
    this->thread_object = t; 
    this->thread_is_running = true;
    plot("in run");
}

void our_thread::join(const char* text)
{
    plot("in join");
    if(this->thread_object == 0) { return; }
    this->thread_is_running = false;
    if(text)
    {
        plot(text);
    }
    plot("progress.show(false);");
    this->thread_object->join();
    this->delete_thread();
}

void our_thread::delete_thread()
{
    this->thread_is_running = false;
    delete this->thread_object;
    this->thread_object = 0;
}

void function_name(std::string param1)
{
    plot("Enter function_name");
    plot(param1);
    boost::this_thread::sleep_for(boost::chrono::seconds(3));
    plot("Leave function_name");
}

int main()
{
    our_thread do_something_thread;
    do_something_thread.run(new boost::thread(&function_name, "param1"));
    // ...
    do_something_thread.join("Part creation finished");
}

你能算出显示你的问题的最小变化吗？然后也许您可以找出原因。