C++中，latch的使用

2024-01-29 00:44

文章标签 c++ 使用 latch

本文主要是介绍C++中，latch的使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

在C++20中，std::latch是并发编程中的一个重要工具(C++17中是std::experimental::latch)，它提供了一个同步原语，使得一组线程可以等待直到某个事件被一定数量的线程观察到后才能继续执行。这是通过一个计数器来实现的，该计数器在std::latch对象构造时被初始化，并且每次调用count_down()会将计数器减1，直到计数器为0，此时所有调用wait()或者尝试通过try_wait()检查计数器状态的线程都将被解除阻塞并允许继续执行。

std::latch特别适用于那些需要等待多个事务完成后才能继续执行的场景，比如并行算法的不同部分需要在继续之前同步完成状态，或者在启动时，程序需要等待多个资源加载完成后才能继续。

以下是std::latch的基本用法示例代码：

#include <latch>
#include <iostream>
#include <thread>// 假设我们需要同步启动5个线程执行任务
const int numberOfThreads = 5;// 初始化一个计数器为5的latch
std::latch latch(numberOfThreads);void worker(int id) {std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟任务执行std::cout << "Worker " << id << " completed.\n";// 线程完成工作，减少latch的计数latch.count_down();
}int main() {std::thread threads[numberOfThreads];// 启动所有线程for (int i = 0; i < numberOfThreads; ++i) {threads[i] = std::thread(worker, i);}// 主线程等待所有的工作线程完成latch.wait();std::cout << "All workers completed.\n";// 等待所有线程结束for (auto& t : threads) {t.join();}return 0;
}