c++

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

小樊
84
2024-08-29 22:41:47
栏目: 编程语言

在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."。

0
看了该问题的人还看了