系统中std::future对象同时存在数量上限及多线程哈希实现疑问

一、std::future对象的数量上限 #

std::future本身就是个轻量级的结果持有对象，理论上没数量上限——只要程序内存够，想创建多少都可以。但你得注意真正的瓶颈不在future本身，而是std::launch::async模式下std::async会创建新线程：系统能同时运行的线程数是有限的（受CPU核心数、系统资源限制），线程太多会引发频繁上下文切换，反而拖慢性能；要是线程数量超标耗尽系统资源，程序直接崩溃都有可能。

说白了：future随便建，但背后的线程资源有天花板，你得控制并发任务的数量（比如用线程池）。

二、你的多线程哈希代码的问题与疏漏 #

你的代码有几个致命问题，会导致程序行为异常甚至崩溃：

1. lambda引用捕获悬空，触发未定义行为
   循环里的promiseHashData是栈上的局部变量，每次循环结束就销毁了。你用[&]引用捕获它，要是异步任务启动慢，执行的时候promiseHashData已经没了，这时候std::move(promiseHashData)操作的是个已销毁的对象，属于未定义行为（程序可能崩溃、结果乱码，啥情况都可能发生）。

2. 丢弃std::async返回的future，等于白写多线程
   std::async返回的std::future有个特性：如果任务是用std::launch::async启动的，这个future被销毁时会阻塞到任务完成。你现在直接丢了这个返回值，每次循环都会等当前哈希任务做完才进下一轮，相当于完全串行执行，根本没用到多线程。

3. messages[i]的捕获有潜在风险
   虽说messages本身可能在任务执行期间有效，但[&]捕获messages[i]时，老版本编译器可能会捕获到循环变量i的引用，导致任务拿到错误的消息；C++11+虽然修复了这个问题，但最好直接值捕获消息副本，更稳妥。

修正后的代码示例 #

最简单的改法是去掉手动管理的promise，让std::async自动处理结果：

std::vector<std::future<HashData>> futures;
std::vector<std::string> messages;

for (const auto& msg : messages) {
    // 直接保存std::async返回的future，不用自己搞promise
    futures.emplace_back(std::async(std::launch::async, [msg]() {
        return PerformHash(msg); // 把PerformHash改成直接返回HashData就行
    }));
}

std::vector<HashData> vectorOfHashData;
for (auto& futureObj : futures) {
    vectorOfHashData.push_back(futureObj.get());
}

关键修正点： #

• 删掉手动的std::promise，用std::async自带的future关联返回值，既简化代码又避免悬空问题。
• 值捕获msg，确保异步任务拿到的是消息副本，不会有引用失效的问题。
• 保存std::async返回的future，避免临时future销毁时阻塞，真正实现并发。

如果没法改PerformHash的接口（必须用promise传结果），那得把promise移动到lambda里，同时保存std::async的返回值：

std::vector<std::future<HashData>> futures;
std::vector<std::string> messages;
std::vector<std::future<void>> asyncTasks; // 保存async返回的future，避免阻塞

for (const auto& msg : messages) {
    std::promise<HashData> promiseHashData;
    futures.emplace_back(promiseHashData.get_future());
    // 把promise移动到lambda里，用值捕获确保所有权转移
    asyncTasks.emplace_back(std::async(std::launch::async, 
        [promise = std::move(promiseHashData), msg]() mutable {
            PerformHash(std::move(promise), msg);
        }));
}

// 等待所有任务执行完成（也可以直接等futures的get，这里是显式等待）
for (auto& task : asyncTasks) {
    task.get();
}

std::vector<HashData> vectorOfHashData;
for (auto& futureObj : futures) {
    vectorOfHashData.push_back(futureObj.get());
}

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