std:: barrier

La plantilla de clase std::barrier proporciona un mecanismo de coordinación de hilos que bloquea un grupo de hilos de tamaño conocido hasta que todos los hilos en ese grupo hayan alcanzado la barrera. A diferencia de std::latch , las barreras son reutilizables: una vez que se desbloquea un grupo de hilos que llegan, la barrera puede reutilizarse. A diferencia de std::latch , las barreras ejecutan un invocable posiblemente vacío antes de desbloquear los hilos.

El tiempo de vida de un objeto barrera consiste en una o más fases. Cada fase define un punto de sincronización de fase donde los hilos en espera se bloquean. Los hilos pueden llegar a la barrera, pero diferir la espera en el punto de sincronización de fase llamando a arrive . Dichos hilos pueden bloquearse posteriormente en el punto de sincronización de fase llamando a wait .

Una barrera phase consiste en los siguientes pasos:

1. El conteo esperado se decrementa con cada llamada a arrive o arrive_and_drop .
2. Cuando el conteo esperado alcanza cero, se ejecuta el paso de completado de fase , lo que significa que se invoca la completion y todos los hilos bloqueados en el punto de sincronización de fase se desbloquean. El final del paso de completado strongly happens-before que todas las llamadas desbloqueadas por el paso de completado retornen.
   Exactamente una vez después de que el conteo esperado alcanza cero, un hilo ejecuta el paso de completado durante su llamada a arrive , arrive_and_drop , o wait , excepto que está definido por la implementación si el paso se ejecuta cuando ningún hilo llama a wait .
3. Cuando el paso de completado finaliza, el conteo esperado se restablece al valor especificado durante la construcción menos el número de llamadas a arrive_and_drop desde entonces, y comienza la siguiente fase de barrera .

Las invocaciones concurrentes de las funciones miembro de barrier , excepto para el destructor, no introducen carreras de datos.

Parámetros de plantilla

El argumento de plantilla predeterminado de CompletionFunction es un tipo de objeto función no especificado que además cumple con los requisitos de DefaultConstructible . Llamar a un lvalue del mismo sin argumentos no tiene efectos.

Tipos de miembros

Miembros de datos

Funciones miembro

Notas

Ejemplo

#include <barrier>
#include <iostream>
#include <string>
#include <syncstream>
#include <thread>
#include <vector>
int main()
{
    const auto workers = {"Anil", "Busara", "Carl"};
    auto on_completion = []() noexcept
    {
        // locking not needed here
        static auto phase =
            "... done\n"
            "Cleaning up...\n";
        std::cout << phase;
        phase = "... done\n";
    };
    std::barrier sync_point(std::ssize(workers), on_completion);
    auto work = [&](std::string name)
    {
        std::string product = "  " + name + " worked\n";
        std::osyncstream(std::cout) << product;  // ok, op<< call is atomic
        sync_point.arrive_and_wait();
        product = "  " + name + " cleaned\n";
        std::osyncstream(std::cout) << product;
        sync_point.arrive_and_wait();
    };
    std::cout << "Starting...\n";
    std::vector<std::jthread> threads;
    threads.reserve(std::size(workers));
    for (auto const& worker : workers)
        threads.emplace_back(work, worker);
}

Starting...
  Anil worked
  Carl worked
  Busara worked
... done
Cleaning up...
  Busara cleaned
  Carl cleaned
  Anil cleaned
... done

Informes de defectos

Los siguientes informes de defectos que modifican el comportamiento se aplicaron retroactivamente a los estándares publicados anteriormente de C++.

Véase también