std::latch用于一次性同步,主线程等待多个工作线程完成任务,计数归零后释放所有线程;std::barrier支持重复使用,适合多轮协作场景,每轮所有线程到达后执行可选完成函数并继续下一轮。

在C++20中,std::latch 和 std::barrier 是两个新的线程同步原语,用于简化多线程程序中的等待逻辑。它们比传统的条件变量更简洁、高效,适用于不同场景下的线程协调。
std::latch:一次性倒计时同步
std::latch 是一个一次性使用的同步机制,它允许一个或多个线程等待,直到一个计数器减到零。一旦计数归零,所有等待的线程被释放,且 latch 不可重用。
常用方法:
count_down(n):将内部计数器减少 n,不会阻塞。wait():阻塞当前线程,直到计数器变为 0。arrive_and_wait(n):等价于 count_down(n) 后调用 wait()。
适用场景:主线程启动多个工作线程,等待它们全部完成某阶段任务。
立即学习“C++免费学习笔记(深入)”;
示例代码:
#include #include #include #includeint main() {std::latch latch(3); // 需要3个线程到达
std::vector 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() 后,所有线程被同时释放,并可以进入下一轮同步。
关键特性:
可多次使用,适合循环协作场景。可选地指定“完成函数”(completion function),在每次所有线程到达后执行一次。
示例:三个线程进行两轮并行计算,每轮结束后同步。
#include #include #include #includeint main() {std::barrier sync_point(3, []{std::cout << "【所有线程完成本轮】n";});
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 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多线程同步原语使用教程的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1483925.html
微信扫一扫
支付宝扫一扫