condition_variable::wait_for 方法没有返回 - 即使在超时之后

Question

我有 C# 编码经验；我开始学习 C++ 并使用 boost 库进行线程处理。 我编写了以下类 - 尝试将成员函数作为线程执行。编写以下简单代码，我希望线程函数内的 while 循环每秒执行一次。

#include <boost/chrono/chrono.hpp>
#include <boost/thread/thread.hpp>
#include <iostream>

using namespace boost;

class MyClassWithThread : public boost::enable_shared_from_this<MyClassWithThread>
{ 
    mutex                           muThreadControl;
    condition_variable              cvThreadControl;
    bool                            threadToBeStopped = false; 

    void ThreadFunction()
    {
        std::cout << "Beginning the Thread" << std::endl;

        while(true)
        {
            bool endIOThread = false;
            std::cout << "\nChecking if Thread to be stopped: ";
            {
                boost::mutex::scoped_lock lock(muThreadControl);
                endIOThread = cvThreadControl.wait_for(lock, 
                    boost::chrono::seconds(1),
                    [this]{return threadToBeStopped;} ) == cv_status::no_timeout;
                std::cout << endIOThread << std::endl
            }
        }
        std::cout << "Exiting the Thread" << std::endl;
    }

public:
    thread                          threadRunner; 
    MyClassWithThread()
    { 
        threadRunner = thread(&MyClassWithThread::ThreadFunction, this);
    }
};


int main(int argc, char* argv[])
{
    MyClassWithThread myclassWithThread;
    myclassWithThread.threadRunner.join();
    return 0;
}

在 Linux 上构建：

g++ -std=c++11 -pthread cond-wait-test.cpp -o cond-wait-test -lboost_system -lboost_thread -lboost_chrono

但是，当我执行代码时，我只注意到线程执行在调用 wait_for 方法时被阻塞；永远。尽管有超时时间。此外，系统的资源监视器显示处理器内核正在 100% 使用。

谁能解释一下代码中发生了什么？

Answer 1

正如@Zan Lynx 所建议的，罪魁祸首是#pragma pack 声明。我最初只使用#pragma pack(1) 来对某些结构进行字节对齐。这影响了许多互斥体结构到 1 字节对齐。

我将#pragma pack(1) 语句更改为#pragma pack(push, 1) #pragma pack(pop)。它一切正常。因此我的问题解决了；我学到了一些东西。多谢。 ！ :-)

Answer 2

你的程序永远不会退出你的 while 循环。

解决方案。

添加某种终止条件。

bool endIOThread = false;
while(!endIOThread)
{
    std::cout << "\nChecking if Thread to be stopped: ";
    {
        boost::mutex::scoped_lock lock(muThreadControl);
        endIOThread = cvThreadControl.wait_for(lock, 
            boost::chrono::seconds(1),
            [this]{return threadToBeStopped;} ) == cv_status::no_timeout;
        std::cout << endIOThread << std::endl
    }
}

Answer 3

我复制了你的代码并在 Linux 上尝试过。

您发布的代码将无法编译。不知道你试过没？

问题是带有谓词重载的wait_for 返回bool 而不是cv_status。内循环超时，调用谓词并返回。

如果我删除谓词 lambda，您的代码将按预期工作。如果我离开 lambda 并删除 == 与 cv_status 的比较，它也可以工作。

也许如果你按照我的做法删除using namespace boost; 行，然后明确所有 Boost 对象。

这是适合我的修改版本：

#include <boost/chrono/chrono.hpp>
#include <boost/thread/thread.hpp>
#include <iostream>

class MyClassWithThread : public boost::enable_shared_from_this<MyClassWithThread>
{
    boost::mutex                           muThreadControl;
    boost::condition_variable              cvThreadControl;
    bool                            threadToBeStopped = false;

    void ThreadFunction()
    {
        std::cout << "Beginning the Thread" << std::endl;

        while(true)
        {
            bool endIOThread = false;
            std::cout << "\nChecking if Thread to be stopped: ";
            {
                boost::mutex::scoped_lock lock(muThreadControl);
#if 1
                endIOThread = cvThreadControl.wait_for(lock,
                    boost::chrono::seconds(1),
                    [this]{return threadToBeStopped;} );
#else
                endIOThread = cvThreadControl.wait_for(lock,
                    boost::chrono::seconds(1)) == boost::cv_status::no_timeout;
                std::cout << endIOThread << std::endl;
#endif
            }
        }
        std::cout << "Exiting the Thread" << std::endl;
    }

public:
    boost::thread                          threadRunner;
    MyClassWithThread()
    {
        threadRunner = boost::thread(&MyClassWithThread::ThreadFunction, this);
    }
};


int main(int argc, char* argv[])
{
    MyClassWithThread myclassWithThread;
    myclassWithThread.threadRunner.join();
    return 0;
}

Linux GCC 构建命令：

g++ -std=c++11 -pthread cond-wait-test.cpp -o cond-wait-test -lboost_system -lboost_thread -lboost_chrono