在多线程环境中交换C 地图对象

swap c++ map objects in multithreaded environment

本文关键字：地图 对象 交换 多线程 环境      更新时间：2023-10-16

我是C 编码的新手，需要交换/替换旧构建的Multimap对象，将其替换为CACHE，我想替换现有对象仅在构建新对象并替换对象本身之后。这将用于多线程环境中，因此使用原子负载。如该线程中所述，需要一种有效的方法来交换C 中的两个指针。我写了这个代码

#include<iostream>
#include<map>
#include<atomic>
#include<string>
using namespace std;
// MultiMap Object
struct mmap{
multimap<string,int> stringTointmap;
};
// Structure to swap two instances of multimap
struct swapMap{
  mmap* m1;
  mmap* m2;
};
int main(){
//create Two Objects
mmap* old = new mmap();
mmap* new2= new mmap();
// populate first object
old->stringTointmap.insert(make_pair("old",1));
//populate second object
new2->stringTointmap.insert(make_pair("new1",2));
//swap two objects
atomic<swapMap> swap;
auto refresh=swap.load();
refresh= {swap.m2,swap.m1};
}

但是我遇到了这个错误

error: expected expression
refresh= {swap.m2,swap.m1};

当然，我缺少某些东西，有人可以帮忙吗？

以下是示例代码，显示了如何在 std::shared_ptr上使用原子操作。

#include <memory>
#include <thread>
#include <chrono>
#include <atomic>
#include <iostream>
std::shared_ptr<std::string> the_string;
int main()
{
    std::atomic_store(&the_string, std::make_shared<std::string>("first string"));
    std::thread thread(
        [&](){
            for (int i = 0; i < 5; ++i)
            {
                {
                    // pin the current instance in memory so we can access it
                    std::shared_ptr<std::string> s = std::atomic_load(&the_string);
                    // access it
                    std::cout << *s << std::endl;
                }
                std::this_thread::sleep_for(std::chrono::seconds(1));
            }
        });
    std::this_thread::sleep_for(std::chrono::seconds(2));
    // replace the current instance with a new instance allowing the old instance
    // to be removed when all threads are done with it
    std::atomic_store (&the_string, std::make_shared<std::string>("second string"));
    thread.join();
}

输出：

第一个字符串
第一个字符串
第二个字符串
第二个字符串
第二个字符串

相关文章：