如何在自定义线程池中传递mongocxx::pool或使其全局可用？

嘿，这个场景我熟！mongocxx::pool本身就是为多线程共享设计的，你遇到的传递问题主要是因为它不可拷贝，所以不能直接按值传递。下面给你两个最常用的靠谱方案：

方案一：用智能指针传递pool #

既然不能拷贝，咱们就用std::shared_ptr来托管pool的生命周期，这样不管是给自定义线程池的任务作为参数，还是让任务捕获这个智能指针，都能安全访问。

举个实际代码例子：

#include <mongocxx/pool.hpp>
#include <mongocxx/uri.hpp>
#include <memory>
// 假设你的自定义线程池有submit方法
#include "your_custom_thread_pool.hpp"

int main() {
    // 先初始化mongocxx的全局实例（必须在pool之前创建）
    mongocxx::instance instance{};

    // 用shared_ptr包装pool
    auto pool_ptr = std::make_shared<mongocxx::pool>(mongocxx::uri{"mongodb://localhost:27017"});

    // 定义线程任务，捕获pool_ptr
    auto db_task = [pool_ptr]() {
        // 从pool获取客户端，线程安全
        auto client = pool_ptr->acquire();
        // 这里用client操作数据库，比如：
        (*client)["test_db"]["test_col"].insert_one({});
    };

    // 提交任务到自定义线程池
    your_custom_thread_pool.submit(db_task);

    // ... 其他逻辑
    return 0;
}

这个方案的好处是生命周期可控，不会有全局变量的初始化顺序问题，而且符合现代C++的编程习惯。

方案二：将pool封装成全局单例 #

如果你希望pool在整个应用里随时可用，单例模式是个经典选择。不过要注意线程安全的初始化，以及确保mongocxx的全局实例先于pool创建。

示例代码：

#include <mongocxx/pool.hpp>
#include <mongocxx/uri.hpp>
#include <mutex>

class GlobalMongoPool {
public:
    // 获取单例实例，线程安全
    static GlobalMongoPool& get_instance() {
        static GlobalMongoPool instance;
        return instance;
    }

    // 获取pool的引用
    mongocxx::pool& get_pool() {
        return pool_;
    }

    // 禁止拷贝和赋值，确保单例唯一性
    GlobalMongoPool(const GlobalMongoPool&) = delete;
    GlobalMongoPool& operator=(const GlobalMongoPool&) = delete;

private:
    // 私有构造函数，确保只能通过get_instance创建
    GlobalMongoPool() {
        // 确保mongocxx全局实例已初始化
        static mongocxx::instance instance{};
        pool_ = mongocxx::pool{mongocxx::uri{"mongodb://localhost:27017"}};
    }

    mongocxx::pool pool_;
};

// 线程中使用的示例
auto thread_task = []() {
    auto& pool = GlobalMongoPool::get_instance().get_pool();
    auto client = pool.acquire();
    // 执行数据库操作
};

这个方案的优势是全局可访问，不用到处传递pool指针，但要注意单例的初始化顺序——上面的代码已经把mongocxx::instance放在了构造函数里，避免了初始化顺序问题。

关键注意事项 #

• mongocxx::pool是线程安全的，多个线程同时调用acquire()完全没问题，每个线程拿到的client是独立的，用完会自动归还给pool。
• 绝对不要尝试拷贝mongocxx::pool对象，它的拷贝构造函数是被删除的，只能通过引用或指针访问。
• 一定要确保mongocxx::instance在pool之前初始化，否则会导致运行时错误。

内容的提问来源于stack exchange，提问作者Julia12