C 11 Thread-Safe Queue: Compreensão e depuração

Você está encontrando uma falha de segmentação em sua implementação de fila thread-safe dentro do função dequeue(), especificamente quando a fila está vazia. Essa anomalia surge porque sua condição de espera, wait_for(lock, timeout) não está estruturada adequadamente para lidar com ativações falsas. como populatedNotifier podem experimentar despertares espúrios, onde são despertados sem que qualquer notificação real ocorra. Esse comportamento é inerente à implementação multithreading subjacente e pode ser imprevisível.

Corrigindo a condição

Para evitar depender de notificações potencialmente não confiáveis, a prática recomendada determina o uso do inverso de a condição desejada como base para seu loop while em dequeue() e funções semelhantes: while (!condition). Dentro deste loop:

Guarde a condição:

Verifique a Condição:
1. Verifique se a fila está vazia (q.empty()).
Aguarde se necessário:
2. Se a fila estiver vazia, libere o bloqueio e digite uma espera a variável de condição.
Verifique novamente a condição:
3. Quando o bloqueio for readquirido, verifique imediatamente novamente a condição para garantir que ela foi alterada.
4. Exemplo de implementação
Aqui está uma versão revisada de sua função dequeue():

std::unique_lock<:mutex> lock(qMutex); enquanto (q.vazio()) { c.wait(bloqueio); if (q.empty()) { // Verifique imediatamente a condição novamente após adquirir o bloqueio retornar std::string(); } } std::string ret = q.front(); q.pop(); return ret;