具有特定超时的 std 线程

Question

目前我启动我的线程并等待它完成：

void ClassA::StartTest() // btn click from GUI
{
    ClassB classB;

    std::vector<std::thread> threads;
    for(int counter=0; counter<4; counter++)
    {
        threads.at(counter) = std::thread(&ClassB::ExecuteTest, classB);
        // if I join the threads here -> no parallelism
    }

    // wait for threads to finish
    for(auto it=threads.begin(); it!=threads.end(); it++)
        it->join();
}

B 类

#include <mutex>

ClassB
{
public:
    void ExecuteTest(); // thread function
private:
    std::mutex m_mutex;
    bool ExecuteOtherWork(std::string &value);
};

相关方法ExecuteTest()

void ClassB::ExecuteTest()
{
    std::string tmp;

    std::lock_guard<std::mutex> lock(m_mutex); // lock mutex
    std::stringstream stream(pathToFile);

    while(getline(stream, tmp, ',')) // read some comma sep stuff 
    {
        if(!ExecuteOtherWork(tmp)) break;
    }
}

一切正常，但我想要线程超时：假设 40 秒后线程必须退出那里工作并返回主线程。 我该怎么做？

谢谢！

Answer 1

在while循环中添加超时检查：

std::chrono::time_point<std::chrono::steady_clock> start(std::chrono::steady_clock::now());
std::chrono::seconds timeout(timeoutinSec);
while(getline(stream, tmp, ',') && std::chrono::steady_clock::now() - start < timeout) // read some comma sep stuff 
{
    if(!ExecuteOtherWork(tmp)) break;
}

如果 ExecuteOtherWork() 是一个快速操作，那么您可以每执行 X 次循环检查一次时间。