Несколько бесконечных нитей

Question

Эй, это не очень практичный пример. Это просто проверить некоторые вещи.

Потоки должны представлять собой независимые объекты ввода, которые произвольно создают данные и отправляют эти данные другому объекту-приемнику.

Моя проблема в том, что я хочу, чтобы они создавали данные в течение бесконечного времени. Но поскольку я запускаю первый поток, он застрял в причине цикла while.

Как можно запустить несколько бесконечных потоков?

класс А:

#pragma once 

#include <iostream> 
#include <thread> 

class A 
{ 

public: 

    A()  : m_ID(-1) {} 
    A(int _ID) : m_ID(_ID) {} 
    ~A()     {} 

public: 

    void DoWork() 
    { 
     std::thread T(&A::Work, this); 

     T.join(); 
    } 

private: 

    void Work() 
    { 
     while (true) 
     { 
      // do stuff 
      std::cout << m_ID << "\n"; 
     } 
    } 

private: 

    int m_ID; 

}; 

main.cpp:

#include "A.h" 

static const unsigned int s_NumberOfObjects = 5; 

void main() 
{ 
    A As[s_NumberOfObjects]; 

    for (size_t i = 0; i < s_NumberOfObjects; i++) 
    { 
     As[i] = A(i); 
    } 


    for (size_t i = 0; i < s_NumberOfObjects; i++) 
    { 
     As[i].DoWork(); 
    } 
} 

Answer 1

сделать нить переменной-члена и переместить join функции к A деструктор

class A{ 
    /* ... */ 

public: 
    ~A() { m_Worker.join(); } 

/*...*/ 
void DoWork() 
{ 
    m_Worker = std::thread(&A::Work, this); 
} 

private: 
    int m_ID; 
    std::thread m_Worker; 

}; 

использованием detach является очень обескуражен, когда вы теряете весь трек для потока, и у вас нет ва y, чтобы сказать, что он закрывается, когда приложение завершается.