1

我在线程练习项目中遇到了一个实现问题。我知道我想要实现什么，但我不知道如何实现。我是 std::future 和 std::async 主题的新手，所以我什至不确定是否可以按照我想象的方式实现。

我有一个具有此功能的NuclearPP 类（它应该是正确的）。

    const error_codes::PPErrorCode& NuclearPowerPlant::Operation(const float& power_required, float& 
    power_generated)
    {
        error_codes::PPErrorCode power_plant_error_code = error_codes::success;

        float energy_required_per_core = power_required / (float)operating_generators_; 

        for (const auto& core_it : reactor_cores_)
        {
            //Threaded call of each core's GenerateEnergy(energy_required_per_core, power_generated)
        }

        //Error handling per core with param power_plant_error_code

        return power_plant_error_code;
    }

我还有一个 NPPCore 类，它有一个产生能量的函数：

 const error_codes::NPPCoreErrorCode& GenerateEnergy(const float& energy_required_per_core, float& 
 produced_energy)
 {
     //Compliacted stuff which adds the generated energy to the shared resource "produced_energy" received as a param
 }

我的问题是：如何为每个 core_it->GenerateEnergy(energy_required_per_core, power_generated) 启动一个线程。

非常感谢转发。如果您需要更多信息，请随时询问。

兄弟，史蒂夫

4

1 回答 1

1

首先 - 定义每个线程应提供的信息。

在这种情况下 - 它可能是这样的：

struct Result
{
     error_codes::NPPCoreErrorCode error;
     float produced_energy;
};

所以你未来的类型是std::future<Result>。

然后在多个线程中开始你的工作：

std::vector<std::future<Result>> results;
for (const auto& core_it : reactor_cores_)
{
    auto action = [&]{
        Result res; 
        res.error = core_it.GenerateEnergy(energy_required_per_core, res.power_generated);
        return res;
    };
    // start thread
    results.emplace_back(std::async(std::launch::async, action));
}

然后等待每个线程完成：

  for (auto& f : results) f.wait();

然后，我想，你想总结一下：


 for (auto& f : results) {
    Result res = f.get();
    if (res.error == error_codes::success)
       power_generated += res.power_generated;
    else {
       power_plant_error_code = res.error;
       // depending on your error strategy, you might break here
       break;
   }
}

在这里阅读更多。

于 2021-01-13T21:08:24.773 回答