c++ std::async 字面上异步关于任务的线程分配

Question

我过去曾成功地使用过 std::async，但最近在检查一些新代码的保真度时，遇到了一个让我难过的怪事。我确信应该有一个简单的解释和一个适当的解决方案，但我在任何地方都找不到关于它的讨论。

下面的一小段代码说明了这个问题:

#include <functional>
#include <thread>
#include <future>
#include <iostream>
#include <sstream>
#include <vector>
#include <algorithm>


int main(int argc, char **argv) {

    for (size_t delay = 0; delay < 2; delay++) {
        std::vector<std::future<std::string>> futures;
        for (size_t i = 0; i < 10; i++) {

            auto fut = std::async(std::launch::async, 
                [&i] () -> std::string
                {
                    std::stringstream ss;
                    ss << "work on number " << i << " " << std::this_thread::get_id();
                    return ss.str();
                }
            );
            if (delay == 1) {
                std::this_thread::sleep_for (std::chrono::milliseconds(10));
            }
            futures.push_back(std::move(fut));
        }

        // do not proceed until all threads are done
        std::for_each(futures.begin(), futures.end(), [](std::future<std::string>& fut) 
            {
                auto codeconf = fut.get();
                std::cout << codeconf << std::endl;
            }
        );
        std::cout << std::endl;
    }
}

如果没有延迟(即第一次通过外循环)，一些循环元素(整数)会丢失并且不会分配给线程/任务，而其他循环元素会分配给多个线程。循环也超出了它的限制:

在 4 号 139770383861504 上工作
处理 4 号 139770375468800
处理 4 号 139770367076096
处理 6 号 139770358683392
处理 5 号 139770350290688
处理 6 号 139770341897984
处理 7 号 139770333505280
处理 8 号 139770325112576
处理 10 号 139770248296192
处理 10 号 139770239903488

包括一个较小的延迟(10 毫秒)允许循环增量和线程按照预期和预期进行对应——即循环增量和任务/线程之间的一对一对应(完成顺序无关紧要，当然，即使它们在这里是有序的):

处理编号 0 139770239903488
处理 1 号 139770248296192
处理 2 号 139770325112576
处理 3 号 139770333505280
处理 4 号 139770383861504
处理 5 号 139770375468800
处理 6 号 139770367076096
处理 7 号 139770358683392
处理 8 号 139770350290688
处理编号 9 139770341897984

我的理解是，异步启动策略应该只获取与循环迭代对应的整数，将其提供给 lambda 函数，并在独立的任务/线程上执行；它什么时候开始(基本上是立即的)和什么时候结束对循环的功能和逻辑并不重要。但在这里，毫不拖延地，“异步”似乎毫不夸张地描述了循环迭代和任务之间的关系。

微小延迟解决方法是否合法？我有什么不明白的？

Answer 1

Without the delay (i.e. first time through the outer loop), some loop-elements (integers) get missed and don't get assigned to a thread/task, while other loop elements get assigned to more than one thread

如果尝试从在该循环中生成的另一个线程访问循环计数器，这是一个直接的危险信号。

在这种情况下，您的任务使用对 i 的引用，它在主线程中递增(并最终销毁)。

您应该将i 的拷贝 传递给每个任务，以便该任务肯定会使用该迭代中i 的任何值.