Блог

я хочу предоставить класс, который содержит буфер при чтении некоторых данных (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(amp;DataCollector::startCollect, std::ref(myDataCollector));

    t1.join();
    return 0;
}
 

но, как я уже сказал, я хотел бы скрыть вызов потока внутри моей функции startCollect.

Перед уничтожением активного thread объекта его необходимо либо присоединить (дождаться завершения потока, затем очистить его ресурсы), либо отсоединить (оставить для запуска и очистки после завершения).).

Таким образом, вы можете либо сделать поток переменной-членом, чтобы к нему можно было присоединиться позже:

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

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

или вы можете отсоединить его, если вам не нужна возможность ждать его завершения, и иметь какой-либо другой способ сигнализации о том, что данные доступны:

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

Вы также можете посмотреть на средства параллелизма более высокого уровня, такие как std::async и std::future . Это может быть удобнее, чем работать с потоками напрямую.