C++如何使用std::barrier和std::latch (C++20)_C++线程同步机制与barrier/latch使用

尼克

发布时间：2025-11-11 21:05:04

997人浏览过

来源于php中文网

原创

std::latch为一次性同步机制，初始化后通过count_down()减少计数，当计数归零时释放所有等待线程，适用于主线程等待多线程完成任务的场景；std::barrier支持重复使用，允许线程在多个阶段到达后继续执行，并可设置完成函数，适合循环协作；两者均需正确匹配线程数量以避免死锁，且应通过引用传递并注意生命周期管理。

c++如何使用std::barrier和std::latch (c++20)_c++线程同步机制与barrier/latch使用

在C++20中，std::barrier 和 std::latch 是两种新的线程同步工具，用于协调多个线程的执行节奏。它们比传统的互斥锁和条件变量更简洁高效，适用于特定的协作场景。

std::latch：一次性倒计数门栓

std::latch 是一个一次性的同步机制，初始化时设定一个计数值，每个线程调用 count_down() 会将计数减一，当计数归零时，所有等待的线程被释放。一旦触发，latch 就永远打开，不能再重置。

常见用途：主线程等待一组工作线程完成任务。

示例代码：

立即学习“C++免费学习笔记（深入）”；

#include 
#include 
#include 
#include 

void worker(int id, std::latch& latch) {
    std::cout << "Worker " << id << " is working...\n";
    // 模拟工作
    std::this_thread::sleep_for(std::chrono::milliseconds(100 * (id + 1)));
    latch.count_down(); // 完成后倒计数减一
}

int main() {
    const int num_threads = 3;
    std::latch latch(num_threads);
    std::vector workers;

    for (int i = 0; i < num_threads; ++i) {
        workers.emplace_back(worker, i, std::ref(latch));
    }

    std::cout << "Main thread waiting for workers...\n";
    latch.wait(); // 等待所有worker完成

    std::cout << "All workers done!\n";

    for (auto& t : workers) {
        t.join();
    }
    return 0;
}

std::barrier：可重复使用的屏障

std::barrier 允许一组线程在某个点上汇合，所有线程都到达后才能继续执行。与 latch 不同的是，barrier 可以多次使用（通过 arrive_and_wait()），适合循环协作场景。

你还可以为 barrier 设置一个“完成函数”（completion function），在每次所有线程到达后自动执行一次。

蕉点AI

AI电商商品图生成平台 | 智能商品素材制作工具

下载

示例代码：

立即学习“C++免费学习笔记（深入）”；

#include 
#include 
#include 
#include 

void participant(int id, std::barrier<>& b) {
    for (int phase = 0; phase < 3; ++phase) {
        std::cout << "Thread " << id << " working in phase " << phase << "\n";
        std::this_thread::sleep_for(std::chrono::milliseconds(50 * (id + 1)));
        b.arrive_and_wait(); // 所有线程必须到达这里
        std::cout << "Phase " << phase << " completed by thread " << id << "\n";
    }
}

int main() {
    const int num_threads = 3;
    std::barrier barrier(num_threads);
    std::vector threads;

    for (int i = 0; i < num_threads; ++i) {
        threads.emplace_back(participant, i, std::ref(barrier));
    }

    for (auto& t : threads) {
        t.join();
    }
    return 0;
}

latch vs barrier：如何选择？

理解两者的差异有助于正确使用：

std::latch 是一次性同步：计数归零后不可恢复，适合“启动后等待完成”的场景。
std::barrier 支持重复使用，适合多阶段协同计算，比如并行迭代算法中的每轮同步。
latch 提供 count_down() 和 wait()，允许不同线程调用不同次数；barrier 要求每个线程在每轮调用一次 arrive_and_wait() 或配对使用 arrive() / wait()。