C++ Темы, имеющие доступ к переменным класса

Question

После использования потоков какое-то время я попал в ситуацию, когда мне нужен поток для запуска навсегда до тех пор, пока не будет вызвана функция (или любое событие). Для этого я создал значение bool для управления циклом while внутри функции, которая была выполнена потоком, но я быстро заметил, что внешние переменные не обновляются после запуска потока, заставляя поток никогда не останавливаться, когда его запрашивали ,

Heres некоторые простой код, чтобы представить этот вопрос:

#include <cstdio> 
#include <thread> 
#include <chrono> 

class A { 
public: 
    A(); 

    void startThread(); 
    void endThread(); 
private: 
    void threadCall(); 
    bool active; 
}; 

int main() { 
    A threadThing; 
    threadThing.startThread(); 
    printf("[M] Thread Created\n"); 
    std::this_thread::sleep_for(std::chrono::seconds(5)); 
    threadThing.endThread(); 
    printf("[M] Thread Killed\n"); 
    std::this_thread::sleep_for(std::chrono::seconds(5)); 

    return 0; 
} 

A::A() { 
    active = false; 
} 

void A::startThread() { 
    active = true; 
    std::thread AThread(&A::threadCall, *this); 
    AThread.detach(); 
} 

void A::endThread() { 
    active = false; 
} 

void A::threadCall() { 
    printf("[T] Thread Started\n"); 
    while (active) { 
     std::this_thread::sleep_for(std::chrono::seconds(2)); 
    } 
    printf("[T] Thread Ended\n"); 
} 

Ожидаемый результат этого будет то, что основная функция запускает поток, поток говорит, что это началось, то 4 секунды спустя поток убит и нить говорит, что это закончилось, когда в действительности нить никогда не говорит, что она заканчивается. Есть ли способ разрешить потоку доступ к «активной» переменной или мой подход к этой проблеме неверен? (Боковое замечание, я попытался понять это самостоятельно, но только получил материал, похожий на локальное хранилище потоков, которое похоже на его хранение только внутри потоков, а не доступ к внешней стороне, но я мог ошибаться)

Answer 1

Проблема с конструктором std::thread, он копирует/перемещает по умолчанию.

std::thread AThread(&A::threadCall, *this); 

это копирует объект в новый поток, поэтому проверка active переменных в новом объекте не имеет никакого эффекта.

вы можете удалить *

std::thread AThread(&A::threadCall, this); 

вы передаете указатель на объект в новый поток, он будет вызывать как метод, как этот (*this).threadCall().

Редактировать: как говорится в комментариях, это не гарантия того, чтобы быть потокобезопасным, вам необходимо использовать std::atomic<bool>, чтобы быть в безопасности.

Answer 2

А, многопоточность.

Что вам нужно сделать, это передать указатель класса A в качестве аргумента вашей функции, которая является вашей нитью.

void A::startThread() 
{ 
    active = true; 
    std::thread AThread(threadCall, this); 
    AThread.detach(); 
} 
void A::threadCall(A *aClass) 
{ 
    printf("[T] Thread Started\n"); 
    while (aClass->active) 
    { 
     std::this_thread::sleep_for(std::chrono::seconds(2)); 
    } 
    printf("[T] Thread Ended\n"); 
}