如何在C++线程类中实现同步操作

在C++中，可以使用互斥锁（std::mutex）和条件变量（std::condition_variable）来实现线程间的同步操作。下面是一个简单的示例，展示了如何在C++线程类中实现同步操作：

#include<iostream>#include<thread>#include <mutex>#include<condition_variable>class ThreadSafeCounter {public:    ThreadSafeCounter() : value_(0) {}    void increment() {        std::unique_lock<std::mutex> lock(mutex_);        ++value_;        condition_.notify_one(); // 通知等待的线程    }    void wait_until_equal(int target) {        std::unique_lock<std::mutex> lock(mutex_);        condition_.wait(lock, [this, target] { return value_ == target; }); // 等待条件满足    }private:    int value_;    std::mutex mutex_;    std::condition_variable condition_;};void worker(ThreadSafeCounter& counter, int target) {    counter.increment();    counter.wait_until_equal(target);}int main() {    const int num_threads = 5;    const int target = num_threads;    ThreadSafeCounter counter;    std::vector<std::thread> threads;    for (int i = 0; i < num_threads; ++i) {        threads.emplace_back(worker, std::ref(counter), target);    }    for (auto& t : threads) {        t.join();    }    std::cout << "All threads finished."<< std::endl;    return 0;}

在这个示例中，我们创建了一个名为ThreadSafeCounter的类，它包含一个整数值、一个互斥锁和一个条件变量。increment()方法用于递增计数器的值，并在递增后通知等待的线程。wait_until_equal()方法用于等待计数器的值达到指定的目标值。

在main()函数中，我们创建了5个线程，每个线程都会调用worker()函数。worker()函数首先调用increment()方法递增计数器的值，然后调用wait_until_equal()方法等待计数器的值达到5。当所有线程都完成时，程序将输出"All threads finished."。