0

0

shared_ptr的线程安全性如何 多线程读写共享对象的正确方式

P粉602998670

P粉602998670

发布时间:2025-07-15 09:04:02

|

647人浏览过

|

来源于php中文网

原创

shared_ptr的引用计数是线程安全的,但其指向的对象并非线程安全。1. shared_ptr的引用计数操作(拷贝、赋值、销毁)是原子性的,确保多个线程可以安全地共享同一个shared_ptr实例;2. 但它不保证所管理对象的并发访问安全,多个线程同时读写该对象会导致数据竞争;3. 解决方案包括使用std::mutex保护共享对象的访问,确保每次操作都加锁;4. 使用不可变对象(immutable objects)并结合std::atomic实现高效读多写少场景;5. 在读远多于写的场景中,可采用std::shared_mutex提升并发性能;6. 实际应用中应根据读写频率和并发需求选择合适的同步机制,以保障线程安全。

shared_ptr的线程安全性如何 多线程读写共享对象的正确方式

shared_ptr本身(特指其内部的引用计数)是线程安全的,这意味着你可以在多个线程中安全地拷贝、赋值或销毁shared_ptr实例,而不会导致引用计数混乱。但它所指向的对象的读写,则完全不是线程安全的。换句话说,shared_ptr只管它自己的生命周期管理,不管你通过它访问的数据是否会被多个线程同时修改而引发问题。

shared_ptr的线程安全性如何 多线程读写共享对象的正确方式

解决方案

要正确地在多线程环境下读写shared_ptr所管理的共享对象,核心原则是:为共享对象的访问提供外部同步机制。这意味着,无论是读取还是写入,任何对shared_ptr所指向的实际数据的操作,都必须被互斥锁(如std::mutex)或其他并发原语保护起来。shared_ptr仅仅保证了其生命周期的管理是原子性的,但它无法替你管理它内部数据的并发访问问题。所以,如果你有一个shared_ptr,并且多个线程都可能通过这个shared_ptr去修改MyData的成员,那么你就需要确保这些修改操作是互斥的。

shared_ptr的引用计数操作真的是线程安全的吗?

说实话,这事儿挺容易让人犯迷糊的。是的,shared_ptr的引用计数操作,包括增加(比如你拷贝一个shared_ptr)和减少(比如一个shared_ptr离开作用域),是原子性的。这是C++标准库明确保证的。这意味着,当多个线程同时对同一个shared_ptr对象进行拷贝、赋值或析构时,其内部的引用计数器不会出现竞争条件,导致计数错误或内存泄漏/过早释放。你可以放心地在线程之间传递shared_ptr,或者在多个线程中持有同一个shared_ptr的副本,它的生命周期管理是稳健的。

shared_ptr的线程安全性如何 多线程读写共享对象的正确方式

但这里有个关键点,也是很多人会误解的地方:这种线程安全仅仅局限于shared_ptr自身的管理逻辑,也就是那个控制块里的引用计数。它并没有延伸到shared_ptr所指向的那个实际对象(T*)的内部状态。想象一下,shared_ptr就像一个门卫,它负责清点有多少人进入和离开了大楼,但它不负责管理大楼里的人在干什么,他们是否会打架。

为什么shared_ptr指向的对象在多线程环境下需要额外保护?

原因很简单,shared_ptr的设计初衷是解决对象的生命周期管理,而不是解决数据竞争。它确保了当最后一个shared_ptr实例被销毁时,它所指向的对象会被正确地释放。但如果多个线程同时尝试修改shared_ptr指向的同一个对象,比如一个std::vector,一个线程在push_back,另一个线程在clear,那么数据就会被破坏,这就是典型的数据竞争

shared_ptr的线程安全性如何 多线程读写共享对象的正确方式

举个例子,你有一个shared_ptr<:map std::string>> myMapPtr;。如果线程A调用myMapPtr->insert({1, "a"});,同时线程B调用myMapPtr->erase(1);,甚至线程C调用myMapPtr->at(1);,这些操作都直接作用于std::map的内部状态。std::map本身并不是线程安全的容器。如果没有额外的同步机制,这些并发操作就会导致未定义行为,程序可能崩溃,也可能产生错误的结果。shared_ptr在此时完全无能为力,因为它只是一个智能指针,它并不知道也不关心你通过它访问的数据会被如何修改。它只是一个“拥有者”的概念,而不是一个“保护者”的概念。

保护共享对象的最佳实践有哪些?

既然shared_ptr不负责数据保护,那我们得自己动手。以下是一些行之有效的方法:

  1. 使用互斥锁(std::mutex)进行同步访问: 这是最常见、最直接也最推荐的方式。当你需要访问或修改shared_ptr指向的对象时,先获取一个锁,操作完成后再释放锁。

    #include 
    #include 
    #include 
    #include 
    #include 
    #include 
    
    class SharedData {
    public:
        void addMessage(const std::string& msg) {
            std::lock_guard lock(mtx_); // 锁定互斥量
            messages_.push_back(msg);
            std::cout << "Added: " << msg << std::endl;
        }
    
        void printMessages() {
            std::lock_guard lock(mtx_); // 锁定互斥量
            std::cout << "Current messages: ";
            for (const auto& msg : messages_) {
                std::cout << msg << " ";
            }
            std::cout << std::endl;
        }
    
    private:
        std::vector messages_;
        mutable std::mutex mtx_; // mutable 允许在 const 成员函数中修改
    };
    
    // 线程函数
    void worker_thread(std::shared_ptr data_ptr, int id) {
        for (int i = 0; i < 3; ++i) {
            data_ptr->addMessage("Hello from thread " + std::to_string(id) + " msg " + std::to_string(i));
            std::this_thread::sleep_for(std::chrono::milliseconds(10)); // 模拟工作
        }
        data_ptr->printMessages();
    }
    
    // int main() {
    //     auto shared_data = std::make_shared();
    //
    //     std::vector threads;
    //     for (int i = 0; i < 3; ++i) {
    //         threads.emplace_back(worker_thread, shared_data, i);
    //     }
    //
    //     for (auto& t : threads) {
    //         t.join();
    //     }
    //
    //     shared_data->printMessages();
    //     return 0;
    // }

    这里,mtx_保护了messages_,确保任何时候只有一个线程能修改或读取messages_

  2. 使用不可变对象(Immutable Objects): 如果你的共享对象在创建后就不会再被修改,那么它就是天然线程安全的。这种情况下,多个线程可以同时读取它而无需任何锁。当需要“修改”时,实际上是创建一个新版本的对象,然后用std::atomic<:shared_ptr>>原子地替换掉旧的shared_ptr。这在读多写少的场景下非常高效。

    #include 
    #include 
    #include 
    #include 
    #include 
    #include 
    
    // 不可变的数据结构
    class ImmutableConfig {
    public:
        ImmutableConfig(const std::map& settings) : settings_(settings) {}
    
        std::string get(const std::string& key) const {
            auto it = settings_.find(key);
            if (it != settings_.end()) {
                return it->second;
            }
            return "N/A";
        }
    
    private:
        const std::map settings_; // const 保证不可变
    };
    
    // 原子操作的shared_ptr,用于替换整个配置
    std::atomic> global_config;
    
    void reader_thread(int id) {
        for (int i = 0; i < 5; ++i) {
            std::shared_ptr current_config = global_config.load(); // 原子加载
            std::cout << "Reader " << id << ": App Name = " << current_config->get("appName")
                      << ", Version = " << current_config->get("version") << std::endl;
            std::this_thread::sleep_for(std::chrono::milliseconds(50));
        }
    }
    
    void writer_thread() {
        std::map initial_settings = {{"appName", "MyService"}, {"version", "1.0"}};
        global_config.store(std::make_shared(initial_settings)); // 原子存储
    
        std::this_thread::sleep_for(std::chrono::milliseconds(200));
    
        std::map new_settings = {{"appName", "MyService"}, {"version", "1.1"}, {"feature", "enabled"}};
        global_config.store(std::make_shared(new_settings)); // 原子存储新版本
    
        std::this_thread::sleep_for(std::chrono::milliseconds(200));
    
        std::map final_settings = {{"appName", "MyService"}, {"version", "1.2"}, {"status", "active"}};
        global_config.store(std::make_shared(final_settings)); // 原子存储最终版本
    }
    
    // int main() {
    //     std::thread writer(writer_thread);
    //     std::vector readers;
    //     for (int i = 0; i < 2; ++i) {
    //         readers.emplace_back(reader_thread, i);
    //     }
    //
    //     writer.join();
    //     for (auto& r : readers) {
    //         r.join();
    //     }
    //     return 0;
    // }

    这里,std::atomic<:shared_ptr>>保证了global_config指针本身的原子替换,而ImmutableConfig内部是const的,因此读取时无需加锁。

  3. 使用读写锁(std::shared_mutex): 如果你的共享对象读操作远多于写操作,std::mutex可能会导致性能瓶颈,因为它每次都完全互斥。std::shared_mutex(C++17引入)允许多个线程同时获取共享锁(用于读),但只允许一个线程获取独占锁(用于写)。

    #include 
    #include 
    #include 
    #include  // C++17
    #include 
    #include 
    #include 
    
    class ThreadSafeMap {
    public:
        void set(const std::string& key, const std::string& value) {
            std::unique_lock lock(mtx_); // 写操作使用独占锁
            data_[key] = value;
            std::cout << "Set: " << key << " = " << value << std::endl;
        }
    
        std::string get(const std::string& key) const {
            std::shared_lock lock(mtx_); // 读操作使用共享锁
            auto it = data_.find(key);
            if (it != data_.end()) {
                return it->second;
            }
            return "Key not found";
        }
    
    private:
        std::map data_;
        mutable std::shared_mutex mtx_;
    };
    
    // int main() {
    //     auto shared_map = std::make_shared();
    //
    //     // 启动写线程
    //     std::thread writer([&]() {
    //         shared_map->set("name", "Alice");
    //         std::this_thread::sleep_for(std::chrono::milliseconds(50));
    //         shared_map->set("age", "30");
    //         std::this_thread::sleep_for(std::chrono::milliseconds(50));
    //         shared_map->set("city", "New York");
    //     });
    //
    //     // 启动读线程
    //     std::vector readers;
    //     for (int i = 0; i < 3; ++i) {
    //         readers.emplace_back([&, i]() {
    //             for (int j = 0; j < 5; ++j) {
    //                 std::cout << "Reader " << i << ": name = " << shared_map->get("name") << std::endl;
    //                 std::this_thread::sleep_for(std::chrono::milliseconds(20));
    //             }
    //         });
    //     }
    //
    //     writer.join();
    //     for (auto& r : readers) {
    //         r.join();
    //     }
    //     return 0;
    // }

    这能有效提升并发读取的性能。

选择哪种方式取决于你的具体场景:如果并发写入频繁,std::mutex通常是最好的选择;如果数据基本不变或更新频率很低但读取非常多,不可变对象和std::atomic<:shared_ptr>的组合会非常高效;如果读写比例差距明显,读写锁则是一个不错的平衡点。但无论如何,切记:shared_ptr不是万能药,它只管“有谁在用”,不管“在用什么”。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

312

2023.08.02

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

519

2023.09.20

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

312

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

522

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

48

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

190

2025.08.29

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

471

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

107

2025.12.24

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

7

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号