在C++中,std::set
是一个基于红黑树实现的关联容器,它会自动对元素进行排序。然而,std::set
并不是线程安全的,因此在多线程环境下使用它可能会导致数据竞争和不一致的结果。
为了在多线程环境下对std::set
进行排序,你可以采用以下方法:
- 使用互斥锁(
std::mutex
)保护对std::set
的访问。在对std::set
进行操作时,首先锁定互斥锁,然后执行操作,最后解锁互斥锁。这样可以确保在同一时间只有一个线程可以访问std::set
。
#include
#include
#include
#include
std::set my_set;
std::mutex mtx;
void insert(int value) {
std::lock_guard lock(mtx);
my_set.insert(value);
}
void print() {
std::lock_guard lock(mtx);
for (const auto& item : my_set) {
std::cout << item << " ";
}
std::cout << std::endl;
}
int main() {
std::thread t1(insert, 5);
std::thread t2(insert, 3);
std::thread t3(insert, 1);
std::thread t4(insert, 4);
std::thread t5(insert, 2);
t1.join();
t2.join();
t3.join();
t4.join();
t5.join();
print();
return 0;
}
- 使用线程安全的容器,如
std::concurrent_set
(C++20中引入)。这个容器在内部实现了适当的同步机制,以确保在多线程环境下的安全性。
#include
#include
#include
int main() {
std::concurrent_set my_set;
std::thread t1([&my_set]() { my_set.insert(5); });
std::thread t2([&my_set]() { my_set.insert(3); });
std::thread t3([&my_set]() { my_set.insert(1); });
std::thread t4([&my_set]() { my_set.insert(4); });
std::thread t5([&my_set]() { my_set.insert(2); });
t1.join();
t2.join();
t3.join();
t4.join();
t5.join();
for (const auto& item : my_set) {
std::cout << item << " ";
}
std::cout << std::endl;
return 0;
}
请注意,std::concurrent_set
在C++20中引入,因此你需要确保你的编译器支持C++20标准。如果你的编译器不支持C++20,你可以使用第一种方法,即使用互斥锁保护对std::set
的访问。