序列化库在C++中的多线程序列化同步

在C++中，使用序列化库（如Boost.Serialization、cereal等）进行多线程序序列化时，需要确保同步以避免数据竞争和不一致

1. 使用互斥锁（std::mutex）：

#include <iostream>
#include <thread>
#include <mutex>
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>
#include <sstream>

class Data {
public:
    int value;

    template<class Archive>
    void serialize(Archive & ar, const unsigned int version) {
        ar & value;
    }
};

std::mutex mtx; // 全局互斥锁

void serializeData(const Data &data, std::stringstream &ss) {
    std::lock_guard<std::mutex> lock(mtx); // 加锁
    boost::archive::text_oarchive oa(ss);
    oa << data;
}

void deserializeData(Data &data, std::stringstream &ss) {
    std::lock_guard<std::mutex> lock(mtx); // 加锁
    boost::archive::text_iarchive ia(ss);
    ia >> data;
}

int main() {
    // ... 多线程环境下调用serializeData和deserializeData
}

2. 使用读写锁（std::shared_mutex）：

#include <iostream>
#include <thread>
#include <shared_mutex>
#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>
#include <sstream>

class Data {
public:
    int value;

    template<class Archive>
    void serialize(Archive & ar, const unsigned int version) {
        ar & value;
    }
};

std::shared_mutex sharedMutex; // 全局读写锁

void serializeData(const Data &data, std::stringstream &ss) {
    std::unique_lock<std::shared_mutex> lock(sharedMutex); // 写锁
    boost::archive::text_oarchive oa(ss);
    oa << data;
}

void deserializeData(Data &data, std::stringstream &ss) {
    std::shared_lock<std::shared_mutex> lock(sharedMutex); // 读锁
    boost::archive::text_iarchive ia(ss);
    ia >> data;
}

int main() {
    // ... 多线程环境下调用serializeData和deserializeData
}

注意：在这些示例中，我们使用了全局锁。在实际应用中，您可能需要根据需求调整锁的范围。例如，您可以为每个数据对象分配一个锁，而不是使用全局锁。这将减少锁的粒度，从而提高性能。