序列化庫在C++中的多線程序列化同步

在C++中，使用序列化庫（如Boost.Serialization、cereal等）進(jìn)行多線程序序列化時，需要確保同步以避免數(shù)據(jù)競爭和不一致

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() {
    // ... 多線程環(huán)境下調(diào)用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() {
    // ... 多線程環(huán)境下調(diào)用serializeData和deserializeData
}

注意：在這些示例中，我們使用了全局鎖。在實(shí)際應(yīng)用中，您可能需要根據(jù)需求調(diào)整鎖的范圍。例如，您可以為每個數(shù)據(jù)對象分配一個鎖，而不是使用全局鎖。這將減少鎖的粒度，從而提高性能。