如何用std::async或std::thread异步处理unordered_map元素？

假设你的无返回值、不修改数据的处理函数定义如下：

void processPair(const std::pair<const std::string, std::string>& kvPair) {
    // 这里写你的处理逻辑，比如打印键值对
    std::cout << "Key: " << kvPair.first << ", Value: " << kvPair.second << std::endl;
}

下面分别给出用std::thread和std::async的实现，填充你代码中// for loop ???的部分：

方式一：使用std::thread #

需要创建线程对象并存储，最后等待所有线程完成执行：

#include <unordered_map>
#include <thread>
#include <vector>

int main() {
    std::unordered_map<std::string, std::string> myMap = {
        {"key1", "val1"}, {"key2", "val2"}, {"key3", "val3"}
    };
    std::vector<std::thread> threads;

    // for loop ??? 处的代码
    for (const auto& kvPair : myMap) {
        // 为每个键值对创建线程，传入处理函数和键值对（用cref避免拷贝）
        threads.emplace_back(processPair, std::cref(kvPair));
        // 若键值对拷贝成本低，也可直接传值：
        // threads.emplace_back(processPair, kvPair);
    }

    // 等待所有线程执行完成
    for (auto& t : threads) {
        if (t.joinable()) {
            t.join();
        }
    }

    return 0;
}

方式二：使用std::async #

std::async会返回std::future对象，存储这些future后通过get()等待所有异步任务完成：

#include <unordered_map>
#include <future>
#include <vector>

int main() {
    std::unordered_map<std::string, std::string> myMap = {
        {"key1", "val1"}, {"key2", "val2"}, {"key3", "val3"}
    };
    std::vector<std::future<void>> futures;

    // for loop ??? 处的代码
    for (const auto& kvPair : myMap) {
        // 指定std::launch::async强制异步执行，避免延迟执行
        futures.emplace_back(std::async(std::launch::async, processPair, std::cref(kvPair)));
        // 若键值对拷贝成本低，也可直接传值：
        // futures.emplace_back(std::async(std::launch::async, processPair, kvPair));
    }

    // 等待所有异步任务完成
    for (auto& f : futures) {
        f.get();
    }

    return 0;
}

关键注意事项 #

• 线程安全：如果处理函数涉及访问共享资源（比如全局变量、其他容器），即使只是读取，也要确保资源的线程安全性，必要时使用std::mutex等同步机制。
• 生命周期：确保myMap的生命周期覆盖所有异步任务的执行时间，避免任务执行时map已被销毁导致的未定义行为。
• 性能考量：若map元素数量极大，创建过多线程会增加上下文切换开销，此时可考虑用线程池限制并发数，避免资源耗尽。

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