linux c++多线程如何同步-乐工具技术知识

在Linux环境下使用C++多线程时，同步是一个重要的问题，以确保数据的一致性和线程安全。C++提供了多种同步机制，包括互斥锁（mutex）、条件变量（condition variable）、读写锁（reader-writer lock）等。以下是一些常见的同步方法：

1. 互斥锁（Mutex）

互斥锁是最基本的同步机制，用于保护共享资源不被多个线程同时访问。

#include 
#include 
#include 

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;
}

2. 条件变量（Condition Variable）

条件变量用于线程间的通信，允许一个线程等待某个条件成立。

#include 
#include 
#include 
#include 

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void print_ready_message() {
    std::unique_lock lck(mtx);
    while (!ready) { // 如果ready为false，则等待
        cv.wait(lck);
    }
    std::cout << "Ready!\n";
}

void set_ready() {
    std::lock_guard lck(mtx);
    ready = true;
    cv.notify_one(); // 唤醒等待的线程
}

int main() {
    std::thread th1(print_ready_message);
    std::thread th2(set_ready);

    th1.join();
    th2.join();

    return 0;
}

3. 读写锁（Reader-Writer Lock）

读写锁允许多个线程同时读取共享资源，但只允许一个线程写入。

#include 
#include 
#include 
#include 

std::shared_mutex rw_mtx; // 读写锁
int data = https://www.yisu.com/ask/0;"hljs">void read_data() {
    std::shared_lock lock(rw_mtx);
    std::cout << "Read: " << data << '\n';
}

void write_data(int value) {
    std::unique_lock lock(rw_mtx);
    data = https://www.yisu.com/ask/value;"Write: " << data << '\n';
}

int main() {
    std::thread th1(read_data);
    std::thread th2(write_data, 42);
    std::thread th3(read_data);

    th1.join();
    th2.join();
    th3.join();

    return 0;
}

4. 原子操作（Atomic Operations）

原子操作是不可中断的操作，用于简单的同步需求。

#include 
#include 
#include 

std::atomic counter(0);

void increment() {
    for (int i = 0; i < 1000; ++i) {
        ++counter;
    }
}

int main() {
    std::thread th1(increment);
    std::thread th2(increment);

    th1.join();
    th2.join();

    std::cout << "Counter: " << counter << '\n';

    return 0;
}