互斥锁用于保护共享资源,C++11提供std::mutex通过lock()和unlock()实现线程同步,防止数据竞争。

在C++中,线程同步是为了防止多个线程同时访问共享资源而导致数据竞争或不一致的问题。C++11起提供了标准库支持,使得线程同步更加方便和安全。以下是几种常见的C++线程同步实现方法。
互斥锁是最基本的线程同步机制,用于保护临界区,确保同一时间只有一个线程可以访问共享资源。
std::mutex的lock()和unlock()方法手动加锁解锁std::unique_lock进行RAII管理,避免忘记解锁示例:
#include <thread>
#include <mutex>
#include <iostream>
std::mutex mtx;
void print_block(int n) {
std::lock_guard<std::mutex> guard(mtx);
for (int i = 0; i < n; ++i) {
std::cout << "*";
}
std::cout << "\n";
}
条件变量用于线程间的通信,常与互斥锁配合使用,实现线程等待某个条件成立后再继续执行。
立即学习“C++免费学习笔记(深入)”;
wait()使线程阻塞,直到被通知且条件满足notify_one()或notify_all()唤醒等待的线程示例:生产者-消费者模型
#include <queue>
#include <condition_variable>
std::queue<int> data_queue;
std::mutex q_mtx;
std::condition_variable cv;
bool finished = false;
void consumer() {
while (true) {
std::unique_lock<std::mutex> lock(q_mtx);
cv.wait(lock, []{ return !data_queue.empty() || finished; });
if (finished && data_queue.empty()) break;
int val = data_queue.front(); data_queue.pop();
lock.unlock();
std::cout << "Consumed: " << val << "\n";
}
}
对于简单的共享变量(如计数器),可使用std::atomic实现无锁同步,性能更高。
原子操作保证读写不可分割,避免数据竞争。
示例:
#include <atomic>
#include <thread>
std::atomic<int> counter(0);
void increment() {
for (int i = 0; i < 1000; ++i) {
counter++; // 原子自增
}
}
C++20之前标准库未提供信号量,但可通过std::counting_semaphore(C++20)或封装条件变量实现。
信号量适合控制对有限资源的访问,比如限制最大并发线程数。
示例(C++20):
#include <semaphore>
std::counting_semaphore<5> sem(5); // 最多5个线程进入
void worker() {
sem.acquire();
// 执行任务
sem.release();
}
基本上就这些。根据场景选择合适的同步方式:互斥锁适用于保护复杂共享数据,原子变量适合简单类型,条件变量用于线程协作,信号量用于资源计数控制。合理使用能有效避免死锁和竞态条件。
以上就是c++++中如何实现线程同步_c++线程同步实现方法的详细内容,更多请关注php中文网其它相关文章!
c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号