A1st0n 最近的时间轴更新 A1st0n 最近的时间轴更新 |
A1st0nV2EX 第 537684 号会员，加入于 2021-03-15 20:56:28 +08:00 |
| CLion 界面字体大小调节问题 C++ • A1st0n • 2024 年 11 月 8 日 • 最后回复来自 Cjkemr | 1 |
A1st0n 最近回复了
2025 年 11 月 13 日 回复了 jiezou 创建的主题 › 生活 › 父母快 55 了，只有农村医保，是否有必要补充重疾险等保险 |
非常有必要
2024 年 11 月 22 日 回复了 zhmouV2 创建的主题 › 分享发现 › DeepSeek 发布了推理模型 R1-Lite-Preview |
感觉 deepseek 在代码问答还不是如 ChatGPT 免费版
2024 年 11 月 20 日 回复了 LuckyPocketWatch 创建的主题 › C++ › 如何保证一个成员函数在另一个成员函数之前获得 mutex? |
使用条件变量：
```
#include <iostream>
#include <mutex>
#include <condition_variable>
#include <thread>
#include <chrono>
class Widget {
public:
void funcA() {
std::unique_lock lock(mutex_);
std::cout << "funcA starts\n";
std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟操作
std::cout << "funcA ends\n";
// 标记 A 已完成，通知等待的线程
funcA_done_ = true;
cv_.notify_one();
}
void funcB() {
// 等待 funcA 完成
std::unique_lock lock(cv_mutex_);
cv_.wait(lock, [this] { return funcA_done_; });
std::unique_lock file_lock(mutex_);
std::cout << "funcB starts\n";
std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟操作
std::cout << "funcB ends\n";
}
private:
std::mutex mutex_; // 用于文件操作的互斥锁
std::mutex cv_mutex_; // 用于条件变量的互斥锁
std::condition_variable cv_; // 条件变量
bool funcA_done_ = false; // 标志 funcA 是否已完成
};
// 封装函数
void execA(Widget* w) {
w->funcA();
}
void execB(Widget* w) {
w->funcB();
}
int main() {
Widget w;
// 使用 std::jthread
std::jthread threadA(execA, &w); // 在一个线程里执行 A 函数
std::jthread threadB(execB, &w); // 在另一个线程里执行 B 函数
return 0;
}
```
```
#include <iostream>
#include <mutex>
#include <condition_variable>
#include <thread>
#include <chrono>
class Widget {
public:
void funcA() {
std::unique_lock lock(mutex_);
std::cout << "funcA starts\n";
std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟操作
std::cout << "funcA ends\n";
// 标记 A 已完成，通知等待的线程
funcA_done_ = true;
cv_.notify_one();
}
void funcB() {
// 等待 funcA 完成
std::unique_lock lock(cv_mutex_);
cv_.wait(lock, [this] { return funcA_done_; });
std::unique_lock file_lock(mutex_);
std::cout << "funcB starts\n";
std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟操作
std::cout << "funcB ends\n";
}
private:
std::mutex mutex_; // 用于文件操作的互斥锁
std::mutex cv_mutex_; // 用于条件变量的互斥锁
std::condition_variable cv_; // 条件变量
bool funcA_done_ = false; // 标志 funcA 是否已完成
};
// 封装函数
void execA(Widget* w) {
w->funcA();
}
void execB(Widget* w) {
w->funcB();
}
int main() {
Widget w;
// 使用 std::jthread
std::jthread threadA(execA, &w); // 在一个线程里执行 A 函数
std::jthread threadB(execB, &w); // 在另一个线程里执行 B 函数
return 0;
}
```
Select Language