首页 关于我们 成功案例 网络营销 电商设计 新闻中心 联系方式
QQ联系
电话联系
手机联系

c++怎么使用std::latch和std::barrier进行线程同步_C++20多线程同步原语使用教程

发布时间:2025-11-14 08:17
发布者:网络
浏览次数:
std::latch用于一次性同步,主线程等待多个工作线程完成任务,计数归零后释放所有线程;std::barrier支持重复使用,适合多轮协作场景,每轮所有线程到达后执行可选完成函数并继续下一轮。

c++怎么使用std::latch和std::barrier进行线程同步_c++20多线程同步原语使用教程

在C++20中,std::latchstd::barrier 是两个新的线程同步原语,用于简化多线程程序中的等待逻辑。它们比传统的条件变量更简洁、高效,适用于不同场景下的线程协调。

std::latch:一次性倒计时同步

std::latch 是一个一次性使用的同步机制,它允许一个或多个线程等待,直到一个计数器减到零。一旦计数归零,所有等待的线程被释放,且 latch 不可重用。

常用方法:

  • count_down(n):将内部计数器减少 n,不会阻塞。
  • wait():阻塞当前线程,直到计数器变为 0。
  • arrive_and_wait(n):等价于 count_down(n) 后调用 wait()。

适用场景:主线程启动多个工作线程,等待它们全部完成某阶段任务。

示例代码:

#include <iostream>
#include <thread>
#include <vector>
#include <latch>
<p>int main() {
std::latch latch(3); // 需要3个线程到达</p><pre class="brush:php;toolbar:false;">std::vector<std::thread> threads;
for (int i = 0; i < 3; ++i) {
    threads.emplace_back([&](int id) {
        std::cout << "线程 " << id << " 完成第一阶段\n";
        latch.count_down(1); // 完成后倒计时减1
    }, i);
}

latch.wait(); // 主线程等待所有线程完成
std::cout << "所有线程已就绪,继续执行...\n";

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

}

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

std::barrier 与 latch 类似,但支持重复使用。当指定数量的线程调用 arrive()arrive_and_wait() 后,所有线程被同时释放,并可以进入下一轮同步。

Perplexity Perplexity

Perplexity是一个ChatGPT和谷歌结合的超级工具,可以让你在浏览互联网时提出问题或获得即时摘要

Perplexity 302 查看详情 Perplexity

关键特性:

  • 可多次使用,适合循环协作场景。
  • 可选地指定“完成函数”(completion function),在每次所有线程到达后执行一次。

示例:三个线程进行两轮并行计算,每轮结束后同步。

#include <iostream>
#include <thread>
#include <vector>
#include <barrier>
<p>int main() {
std::barrier sync_point(3, []{
std::cout << "【所有线程完成本轮】\n";
});</p><pre class="brush:php;toolbar:false;">auto worker = [&](int id) {
    for (int round = 0; round < 2; ++round) {
        std::cout << "线程 " << id << " 执行第 " << round + 1 << " 轮\n";
        std::this_thread::sleep_for(std::chrono::milliseconds(100 * (id + 1)));
        sync_point.arrive_and_wait(); // 等待其他线程完成本轮
    }
};

std::vector<std::thread> threads;
for (int i = 0; i < 3; ++i) {
    threads.emplace_back(worker, i);
}

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

}

latch 与 barrier 的选择建议

根据使用需求决定:

  • 如果只需要一次等待(如初始化完成、任务结束通知),用 std::latch 更轻量。
  • 如果多个阶段需要反复同步(如并行迭代算法),则选择 std::barrier
  • 两者都不支持动态调整参与线程数,设计时需提前确定数量。

基本上就这些。这两个新工具让C++20的多线程同步更直观、安全,减少了手动管理条件变量的复杂性。不复杂但容易忽略的是:确保每个线程对 latch/barrier 的调用次数正确,避免死锁或未定义行为。

以上就是c++++怎么使用std::latch和std::barrier进行线程同步_C++20多线程同步原语使用教程的详细内容,更多请关注其它相关文章!


# 工具  # ai  # c++  # ios  # stream  # 同步机制  # 多线程  # 多个  # 是一个  # 重复使用  # 死锁  # 可选  # 如何使用  # 本轮  # 倒计时  # 如何实现  # 晋江网站建设方案书  # 淘宝seo新浪博客  # facebook海外营销推广的服务态度  # 外网装饰画网站推广文案  # 潼南高效网站建设团队  # 忻州市网站优化  # 神马seo优化方案  # 企业网站建设网站制作  # 青岛靠谱网站建设平台  # 营销活动推广进度计划