在C++中,处理多线程同步的关键是使用线程安全的数据结构和同步原语。以下是一些建议的方法来处理多线程同步:
#include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx; // 全局互斥锁
int shared_data = 0;
void increment() {
mtx.lock(); // 获取锁
shared_data++;
mtx.unlock(); // 释放锁
}
int main() {
std::thread t1(increment);
std::thread t2(increment);
t1.join();
t2.join();
std::cout << "Shared data: " << shared_data << std::endl;
return 0;
}
#include <iostream>
#include <thread>
#include <atomic>
std::atomic<int> shared_data(0);
void increment() {
shared_data++;
}
int main() {
std::thread t1(increment);
std::thread t2(increment);
t1.join();
t2.join();
std::cout << "Shared data: " << shared_data << std::endl;
return 0;
}
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
int shared_data = 0;
void worker() {
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, []{ return shared_data > 0; }); // 等待条件满足
shared_data--;
cv.notify_one(); // 通知其他线程
}
int main() {
std::thread t1(worker);
std::thread t2(worker);
t1.join();
t2.join();
return 0;
}
std::shared_ptr
和std::atomic
,它们可以在多线程环境中安全地使用。总之,处理多线程同步的关键是使用适当的同步原语,如互斥锁、原子操作、条件变量等。在设计多线程程序时,需要仔细考虑共享资源的访问和修改,以确保线程安全。
辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读: c++定义全局变量的方法是什么