您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
C++ 多线程库提供了一些函数和类来实现并发控制策略,主要包括互斥锁(mutex)、条件变量(condition variable)和原子操作(atomic operations)等
std::mutex
类提供了互斥锁的实现。示例代码:
#include<iostream>
#include<thread>
#include <mutex>
std::mutex mtx; // 全局互斥锁
int shared_data = 0; // 共享数据
void thread_function() {
std::unique_lock<std::mutex> lock(mtx); // 获取互斥锁
++shared_data; // 修改共享数据
lock.unlock(); // 释放互斥锁
}
int main() {
std::thread t1(thread_function);
std::thread t2(thread_function);
t1.join();
t2.join();
std::cout << "Shared data: "<< shared_data<< std::endl;
return 0;
}
std::condition_variable
类提供了条件变量的实现。示例代码:
#include<iostream>
#include<thread>
#include <mutex>
#include<condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false; // 共享状态
void worker_thread() {
std::unique_lock<std::mutex> lock(mtx);
while (!ready) { // 如果共享状态为 false,则等待
cv.wait(lock);
}
std::cout << "Worker thread is ready."<< std::endl;
}
void main_thread() {
std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟延迟
{
std::unique_lock<std::mutex> lock(mtx);
ready = true; // 修改共享状态
}
cv.notify_one(); // 唤醒等待的线程
}
int main() {
std::thread worker(worker_thread);
main_thread();
worker.join();
return 0;
}
std::atomic
类模板提供了原子操作的实现。原子操作通常用于实现无锁数据结构和高性能的并发算法。示例代码:
#include<iostream>
#include<thread>
#include<atomic>
std::atomic<int> shared_data(0); // 原子整数类型的共享数据
void thread_function() {
++shared_data; // 原子操作,自增 1
}
int main() {
std::thread t1(thread_function);
std::thread t2(thread_function);
t1.join();
t2.join();
std::cout << "Shared data: "<< shared_data.load()<< std::endl;
return 0;
}
这些并发控制策略可以根据具体的应用场景和需求进行组合使用,以实现高效、安全的多线程编程。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。