Тестирование, если объект не удален

Question

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

class A 
{ 
    shared_ptr<int> guard = make_shared<int>(0); 
public: 
    weak_ptr<int> getGuard() { return guard; } 
    void method() {} 
    A() 
    { 
     thread([this] 
     { 
      const auto &guard = getGuard(); 
      while(!guard.expired()) 
       method(); 
     }); 
    } 
}; 

Answer 1

Если вы хотите, чтобы убедиться, что объект не уничтожается, а вы звоните в method, но может быть уничтожен в другое время, вам необходимо держите weak_ptr на самом объекте и заблокируйте его, пока вы вызываете метод. Что-то вроде:

class A : std::enable_shared_from_this<A> 
{ 
public: 
    void method() {} 
    A() 
    { 
     std::weak_ptr<A> self(shared_from_this()); 
     thread([=self] 
     { 
      while (auto This = self.lock()) 
       This->method(); 
     }).detach(); 
    } 
}; 

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

Answer 2

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

безопасный способ выполнить эту проверку, чтобы попытаться продвинуть слабый указатель на общий указатель:

while (true) 
{ 
    shared_ptr<int> sp = getGuard().lock(); 
    if (sp) 
    { 
     method(); 
    } 
    else 
    { 
     return; 
    } 
} 

Способствуя слабый указатель на общий указатель, то вызывающий код участвует в собственности на объект на время вызова method, гарантируя, что он не может быть уничтожен во время использования вызывающего кода.

Вы также не смогли подключить или отсоединить нить. Из вашего примера видно, что вы хотите отделить его так, чтобы конструктор A мог выйти, прежде чем поток завершит выполнение. В этом случае ваш код должен выглядеть следующим образом:

thread([this] 
{ 
    ... 
}).detach();