c++ - 1 个线程工作但导致调用方法不返回的线程问题

Question

我目前正在学习 C++，但我遇到了一个关于线程的奇怪问题。我已经用 Java 和 C# 完成了很多线程化的工作，但没有遇到任何问题。我目前正在尝试使用库和测试应用程序复制我在 C++ 中拥有的 C# 库。

在 main.cpp 中，我创建了一个 InitialiseLibrary 类的实例并调用方法 initialise。这会加载配置，然后应该启动一个线程，该线程在应用程序运行期间一直保持运行状态。我期待这个线程启动，然后我的初始化函数返回 true 然后我继续并创建一个测试类的实例，它每 1 秒写入一个日志文件。

下面是main.cpp

InitialiseLibrary initLibrary("config.ini");
        if (!initLibrary.initialise(1))
        {
            cout << "Failed to initialise library" << endl;
            return EXIT_FAILURE;
        }
TestClass testClass;
        testClass.writeSomeLogsInThread();


        cout << "The library config log file is: " << GlobalConfig::GeneralConfig::logFile << endl;

在我的 Initialise 方法中(在库中)我有:

bool InitialiseLibrary::initialise(int applicationAlarmID, int applicationTerminationTimeout)
{
    //statusManager.setApplicationStatus(StatusManager::ApplicationStatus::Starting);
    if (!this->loadInconfiguration(applicationAlarmID))
    {
        cout << "*****Failed to configuration. Cannot continue******" << endl;
        return false;
    }

    GlobalConfig::libraryInitialised = true;
    LogRotation logRotation;
    logRotation.startLogRotation();
    BitsLibrary bitsLibrary;
    //Set up the signal handler if its needed, 0 means it terminates instantly, doesn't wait -1 is don't use signal handler
    if (applicationTerminationTimeout >= 0)
    {
        bitsLibrary.setupSignalHandler(applicationTerminationTimeout);
    }
    return true;
}

如您所见，我读入了配置，然后调用 `logRotation.startLogRotation()。

我有以下代码:

void LogRotation::startLogRotation()
{
    //Is the configuration successfully loaded
    if (!LogRotateConfiguration::configurationLoaded)
    {
        throw exception("Log Rotation not initialised");
    }
    BitsLibrary bitsLibrary;
    stringstream logStream;
    logStream << "Log rotation thread starting, monitor cycle time is " << LogRotateConfiguration::archiveSleepTimeInSeconds << " second(s)";
    bitsLibrary.writeToLog(logStream.str(), "LogRotation", "startLogRotation");
    thread logRotationThread(&LogRotation::logRotationThread, this);
    logRotationThread.join();
}

void LogRotation::logRotationThread()
{
    BitsLibrary bitsLibrary;
    while (bitsLibrary.getApplicationStatus() == StatusManager::ApplicationStatus::Starting || bitsLibrary.getApplicationStatus() == StatusManager::ApplicationStatus::Running)
    {
        bitsLibrary.writeToLog("Running log monitoring");
        this_thread::sleep_for(chrono::seconds(LogRotateConfiguration::archiveSleepTimeInSeconds));
    }
    stringstream logStream;
    logStream << "Log rotation archive monitoring stopped. Current application status: " << bitsLibrary.getApplicationStatus();
    bitsLibrary.writeToLog(logStream.str(), "LogRotation", "logRotationThread");
}

在这里，我期望 startLogRotation() 开始在线程中运行方法 logRotationThread，线程启动，startLogrotation() 方法完成并返回堆栈到返回 true 的 initialise() 方法，返回到 main，然后我可以在线程中调用我的 TestClass 方法。

但是由于某种原因，线程启动并每隔几秒保持日志记录 Running log monitoring 所以我知道线程已经启动，但它似乎没有返回到初始化函数以返回是的，所以应用程序会卡在该函数调用上，不会再继续了。

我读到您需要在线程上运行 join 以使其与主线程保持同步，否则主线程退出，而新线程正在运行并导致 SIGABRT实际上确实如此，但是在那里加入似乎会停止方法返回。

Answer 1

join 等待线程完成执行，因此当您加入时，startLogRotation 直到发生时才会返回。

此外，作用域和生命周期的正常规则适用于线程对象 - logRotationThread 将在 startLogRotation 返回时被销毁。
如果线程在销毁时是“可连接的”，这是一个错误。

最简单的解决方案可能是在 InitialiseLibrary 中有一个 LogRotation 成员，在 LogRotation 中有一个 thread 成员。

然后您可以加入 LogRotation 的析构函数中的线程。