C++ 函数的进阶指南：多线程注意事项

// 创建互斥锁

std::mutex m;

// 在函数中使用互斥锁保护共享变量

void incrementCounter() {

// 获取互斥锁

m.lock()搭建源码点我wcqh.cn;

// 对共享变量增量

++counter;

// 解锁互斥锁

m.unlock();

}

登录后复制

// 使用 volatile 关键字确保变量的内存可见性

volatile int sharedVariable;

登录后复制

// 使用 TLS 存储线程特定数据

thread_local int threadLo搭建源码点我wcqh.cncalData;

登录后复制

int sum = 0;

#pragma omp parallel for

for (int i = 0; i < arraySize; i++) {

sum += array[i];

}

登录后复制

// 使用信号量实现生产者-消费者问题

std::condition_variable cv;

std::mutex m;

std::queue<int> buffer;

int bufferSize;

// 生产者线程

void producer() {

while (true) {

// 如果缓冲区已满，等待

std::unique_lock<std::mutex> lock(m);

cv.wait(lock, [] { return buffer.size() < bufferSize; });

// 生产数据并将其添加到缓冲区

buf搭建源码点我wcqh.cnfer.push(data);

// 通知消费者线程有新数据

cv.notify_one();

}

}

// 消费者线程

void consumer() {

while (true) {

// 如果缓冲区为空，等待

std::unique_lock<std::mutex> lock(m);

cv.wait(lock, [] { return !buffer.empty(); });

// 从缓冲区消费数据

data = buffer.front();

buffer.pop();

// 通知生产者线程有空闲空间

cv.notify_one();

}

}

登录后复制