在多线程编程中，线程之间的同步是非常重要的，以确保共享资源的安全访问。C++11引入了一套新的线程库，提供了多种工具来实现线程同步，包括锁机制、条件变量等。
1. 线程同步的必要性
多线程程序中，多个线程可能会同时访问同一共享资源，例如一个变量、数组或数据结构。如果没有正确的同步机制，将会导致数据竞争和不一致性现象。
1.1 数据竞争
数据竞争（Data Race）发生在两个或多个线程访问同一共享变量，其中至少一个线程在写入该变量，而没有适当的同步机制。这可能导致程序输出不可预测的结果。
1.2 解决数据竞争
通过同步机制，确保同一时间只有一个线程能够访问共享资源，从而解决数据竞争问题。
2. 锁机制
C++提供了几种锁机制来实现线程同步，最常用的是std::mutex。
2.1 std::mutex
std::mutex 是一个互斥量，能够确保同一时刻只有一个线程能够访问特定的资源。
使用方式
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
| #include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx;
int shared_data = 0;
void increment() {
for (int i = 0; i < 100000; ++i) {
mtx.lock();
++shared_data;
mtx.unlock();
}
}
int main() {
std::thread t1(increment);
std::thread t2(increment);
t1.join();
t2.join();
std::cout << "Final value of shared_data: " << shared_data << std::endl;
return 0;
}
|
在上面的代码中，两个线程都在对shared_data变量进行递增操作。通过mtx.lock()和mtx.unlock()来确保同一时刻只有一个线程能修改shared_data。
2.2 std::lock_guard
std::lock_guard是一个RAII风格的锁，能够自动管理锁的生命周期。它在构造时自动加锁，在析构时自动解锁。
使用方式
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
| #include <iostream>
#include <thread>
#include <mutex>
std::mutex mtx;
int shared_data = 0;
void increment() {
for (int i = 0; i < 100000; ++i) {
std::lock_guard<std::mutex> lock(mtx);
++shared_data;
}
}
int main() {
std::thread t1(increment);
std::thread t2(increment);
t1.join();
t2.join();
std::cout << "Final value of shared_data: " << shared_data << std::endl;
return 0;
}
|
使用std::lock_guard可以减少手动管理锁的复杂度，避免死锁的风险。
3. 条件变量
当线程需要等待某个条件满足时，std::condition_variable可以用来进行线程间的通信。
使用方式
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
| #include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void wait_for_ready() {
std::unique_lock<std::mutex> lock(mtx);
cv.wait(lock, [] { return ready; });
std::cout << "Thread proceeding after being notified." << std::endl;
}
void go() {
std::unique_lock<std::mutex> lock(mtx);
ready = true;
cv.notify_one();
}
int main() {
std::thread t1(wait_for_ready);
std::thread t2(go);
t1.join();
t2.join();
return 0;
}
|
在此案例中，wait_for_ready函数会等待ready变为true，而go函数会改变这个条件并通知等待线程。
4. 总结
在C++中，线程同步是一个关键的主题，通过使用锁机制，例如std::mutex和std::lock_guard，可以确保数据的一致性和完整性。同时，std::condition_variable提供了线程间的高效通信手段。这些工具的正确使用能够显著提高多线程程序的安全性和性能。通过避免数据竞争和使用适当的同步手段，多线程编程将变得更为可靠。
