在Linux环境下,C++多线程同步主要有以下几种方法:
std::mutex
类来实现互斥锁。#include <iostream>
#include <mutex>
#include <thread>
std::mutex mtx;
void print_block(int n, char c) {
mtx.lock();
for (int i = 0; i < n; ++i) {
std::cout << c;
}
std::cout << '\n';
mtx.unlock();
}
int main() {
std::thread th1(print_block, 50, '*');
std::thread th2(print_block, 50, '$');
th1.join();
th2.join();
return 0;
}
std::recursive_mutex
类来实现递归互斥锁。#include <iostream>
#include <mutex>
#include <thread>
std::recursive_mutex mtx;
void print_block(int n, char c, int depth = 0) {
if (depth > 0) {
mtx.lock();
}
for (int i = 0; i < n; ++i) {
std::cout << c;
}
std::cout << '\n';
if (depth > 0) {
mtx.unlock();
}
}
int main() {
std::thread th1(print_block, 50, '*', 1);
std::thread th2(print_block, 50, '$', 2);
th1.join();
th2.join();
return 0;
}
std::condition_variable
类来实现条件变量。#include <iostream>
#include <mutex>
#include <condition_variable>
#include <thread>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void print_id(int id) {
std::unique_lock<std::mutex> lck(mtx);
cv.wait(lck, []{return ready;});
std::cout << "Thread " << id << '\n';
}
void go() {
std::lock_guard<std::mutex> lck(mtx);
ready = true;
cv.notify_all();
}
int main() {
std::thread threads[10];
for (int i = 0; i < 10; ++i) {
threads[i] = std::thread(print_id, i);
}
std::this_thread::sleep_for(std::chrono::seconds(1));
go();
for (auto &th : threads) {
th.join();
}
return 0;
}
std::shared_mutex
类来实现读写锁。#include <iostream>
#include <shared_mutex>
#include <thread>
std::shared_mutex rw_mtx;
void read_block(int n, char c) {
std::shared_lock<std::shared_mutex> lck(rw_mtx);
for (int i = 0; i < n; ++i) {
std::cout << c;
}
std::cout << '\n';
}
void write_block(int n, char c) {
std::unique_lock<std::shared_mutex> lck(rw_mtx);
for (int i = 0; i < n; ++i) {
std::cout << c;
}
std::cout << '\n';
}
int main() {
std::thread th1(read_block, 50, '*');
std::thread th2(write_block, 50, '$');
th1.join();
th2.join();
return 0;
}
这些同步方法可以帮助你在Linux环境下使用C++多线程编程时保护共享资源,避免数据竞争和其他并发问题。