AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 77859822
Accepted
SpeakX
SpeakX
Asked: 2024-01-22 20:23:25 +0800 CST2024-01-22 20:23:25 +0800 CST 2024-01-22 20:23:25 +0800 CST

Atualizar se não expirou no ponteiro fraco no contexto multithread

  • 772

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_pointerexpirou e, se não estiver, é excluído de um vetor seguro. Suspeito que isso não funcionaria, pois poderia shared_ptrser 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 lambdafunçã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::updatee client::subcribe_sleep_printesteja rodando em threads diferentes. Isso não é seguro, pois shared_ptrpode 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.

c++
  • 1 1 respostas
  • 64 Views

1 respostas

  • Voted
  1. Best Answer
    Ext3h
    2024-01-22T20:30:28+08:002024-01-22T20:30:28+08:00
            else *wd += 2.0; //This is not thread safe I guess?
    

    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ém expired()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.

       m_values.safe_remove_all(nullptr);
       m_values.safe_visit(updater);
    

    Tenho certeza de que você entendeu errado o pedido. Você pretendia primeiro atualizar e depois eliminar o nullptrretorno de chamada de atualização produzido.

    • 0

relate perguntas

  • Por que os compiladores perdem a vetorização aqui?

  • Erro de compilação usando CMake com biblioteca [fechada]

  • Erro lançado toda vez que tento executar o premake

  • Como criar um tipo de octeto semelhante a std::byte em C++?

  • Somente operações bit a bit para std::byte em C++ 17?

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Por que esse código Java simples e pequeno roda 30x mais rápido em todas as JVMs Graal, mas não em nenhuma JVM Oracle?

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Quando devo usar um std::inplace_vector em vez de um std::vector?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Marko Smith

    Estou tentando fazer o jogo pacman usando apenas o módulo Turtle Random e Math

    • 1 respostas
  • Martin Hope
    Aleksandr Dubinsky Por que a correspondência de padrões com o switch no InetAddress falha com 'não cobre todos os valores de entrada possíveis'? 2024-12-23 06:56:21 +0800 CST
  • Martin Hope
    Phillip Borge Por que esse código Java simples e pequeno roda 30x mais rápido em todas as JVMs Graal, mas não em nenhuma JVM Oracle? 2024-12-12 20:46:46 +0800 CST
  • Martin Hope
    Oodini Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores? 2024-12-12 06:27:11 +0800 CST
  • Martin Hope
    sleeptightAnsiC `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso? 2024-11-09 07:18:53 +0800 CST
  • Martin Hope
    The Mad Gamer Quando devo usar um std::inplace_vector em vez de um std::vector? 2024-10-29 23:01:00 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST
  • Martin Hope
    MarkB Por que o GCC gera código que executa condicionalmente uma implementação SIMD? 2024-02-17 06:17:14 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve