O cliente mantém um ponteiro compartilhado para um valor, digamos double
, e um servidor atualiza esse valor em outro thread desanexado, mantendo um weak_pointer
, o servidor verifica se weak_pointer
expirou e, se não estiver, é excluído de um vetor seguro. Suspeito que isso não funcionaria, pois poderia shared_ptr
ser destruído do lado do cliente entre minha leitura expired()
(que considero thread-safe, pois imagino que se refere ao contador atômico de shared_ptr
) e minha atualização do valor. Existe uma maneira de fazer com que a verificação expired()
e uma lambda
função atualizem o valor antes que ele seja destruído, por favor? Quero dizer:
struct server
{
public:
static void subscribe(const std::shared_ptr<double>& d)
{
m_values.safe_push_back(d); //safely pushes back in the vector
}
void update()
{
auto updater = [](std::weak_ptr<double>& wd)
{
if(wd.expired()) wd = nullptr;
else *wd += 2.0; //This is not thread safe I guess?
};
m_values.safe_remove_all(nullptr);
m_values.safe_visit(updater);
};
private:
static safe_vector<std::weak_ptr<double>> m_values;
}
struct client
{
void subcribe_sleep_print(const double random_seconds)
{
std::shared_ptr<double> d = std::make_shared<double>(0.0); //for the sake of the example assume we create subscribe before sleep
server::subscribe(d);
sleep_for_seconds(random_seconds); //sleeps for some random time in seconds.
std::cout << *d << std::endl;
}
}
Imagine server::update
e client::subcribe_sleep_print
esteja rodando em threads diferentes. Isso não é seguro, pois shared_ptr
pode ser destruído enquanto o servidor está gravando? Existe uma maneira de fazer isso sem atômicos ou mutexes definidos pelo usuário (eu)? Não me importo se for usado em segundo plano, desde que eu mesmo não os adicione (atômico/mutex), pois sei que o ponteiro compartilhado já usa um contador atômico.
EDIT : Não estou usando double no meu programa, estou usando um objeto thread-safe :) Portanto, a operação += pode ser assumida como thread-safe. Desculpe.
Não, não é seguro para threads. Você está enfrentando uma condição de corrida em que o ponteiro pode expirar logo após você ter verificado a expiração. Nesse caso, você agora desreferenciau um arquivo
nullptr
.Portanto, o caminho a seguir é usar explicitamente
std::weak_ptr<T>::lock()
para tentar obter o ponteiro compartilhado associado (que tambémexpired()
foi feito internamente), e somente se obtiver um ponteiro válido você poderá fazer um acesso de leitura ou gravação.Se você não obteve um ponteiro compartilhado válido, trate-o como se
expired()
tivesse retornado falso.Tenho certeza de que você entendeu errado o pedido. Você pretendia primeiro atualizar e depois eliminar o
nullptr
retorno de chamada de atualização produzido.