C++11 线程 - 从类内部启动无限工作线程

Question

我想提供一个类，它在读取某些数据（udp 数据包或从文件）时保存一个缓冲区。如果我从主线程开始，一切都很好，但在这种情况下，我想避免用户必须为自己设置一个新线程。

所以我的代码尽可能简单：

class DataCollector
{
    void startCollect()
    {
        std::thread t1(readSource);
    }

    bool readSource()
    {
        while(1)
        {
            // read some data for storage
        }
    }   
}

int main()
{
    DataCollector myDataCollector;
    myDataCollector.startCollect();

    while(1)
    {
        // do some other work, for example interpret the data
    }

    return 0;
}

现在我需要你的帮助。如何在 startCollect 中调用这个线程？

编辑1： 这是我现在如何工作的示例！

// ringbuffertest.cpp : Definiert den Einstiegspunkt für die Konsolenanwendung.
//

#include "stdafx.h"
#include <thread>
#include <Windows.h>

class DataCollector
{
private:
    //std::thread collecterThread;

public:
    DataCollector(){}

    void startCollect()
    {       
        readSource();
    }

    bool readSource()
    {
        while (1)
        {
            printf("Hello from readSource!\n");
            Sleep(1000);
        }
        return false;
    }
};


int _tmain(int argc, _TCHAR* argv[])
{
    DataCollector myDataCollector;

    std::thread t1(&DataCollector::startCollect, std::ref(myDataCollector));

    t1.join();
    return 0;
}

但正如我所说，我想将线程调用隐藏在我的 startCollect 函数中。

Answer 1

在销毁活动的thread 对象之前，它必须加入（等待线程完成，然后清理其资源）或分离（留给完成后运行并自行清理）。

所以你可以让线程成为成员变量，以便以后可以加入：

void startCollect()
{
    this->thread = std::thread(&DataCollector::readSource, this);
}

void waitForCollectToFinish()
{
    this->thread.join();
}

或者你可以分离它，如果你不需要等待它完成的能力，并且有一些其他的方式来表示数据可用：

void startCollect()
{
    std::thread([this]{readSource();}).detach();
}

您还可以查看更高级别的并发工具，例如 std::async 和 std::future。这些可能比直接处理线程更方便。