C++ std::future在单独的内核上运行每个函数

c++ std::future running each function on a separate core

本文关键字：运行 函数 内核 std future 单独 C++      更新时间：2023-10-16

这是一个在四核Cortex A9 ARMv7（Linux和gcc 4.8.2）上运行的实时音频应用程序，这是处理实际音频（通过调用其他函数）并发送到音频驱动程序的部分：

struct STEREOOUT
{
    std::vector<float> L;
    std::vector<float> R;
};
STEREOOUT ProcessEngine(int e, unsigned int sf)
{
    STEREOOUT out;
    for (unsigned int s=0; s<sf; ++s)
    {
        float l, r; 
        engine[e]->Process(l, r);
        out.L.push_back(l);
        out.R.push_back(r);
    }
    return out;
}
// This is the main audio loop callback!
int AudioProcess(void *outputBuffer, unsigned int sampleFrames)
{
    float *buffer = (float*)outputBuffer;
    unsigned int s(0);
    STEREOOUT e0 = async(launch::async, &ProcessEngine, 0, sampleFrames).get();
    STEREOOUT e1 = async(launch::async, &ProcessEngine, 1, sampleFrames).get();
    for (; s<sampleFrames; ++s)
    {
        *buffer++ = e0.L[s] + e1.L[s];
        *buffer++ = e0.R[s] + e1.R[s];
    }
    return 0;
}

如何确保e1和e2以与main()程序不同的相关性运行，但彼此之间又不同？例如： 

main() -> CPU0
e1 -> CPU1
e2 -> CPU2

我的代码，当你在这里看到的编译时，似乎仍然在单个内核上运行。我需要两个音频处理占用两个不同的内核，以便充分利用四核处理器的全部功能。我只是在做梦吗？

PS：我知道，我过去已经发布了类似的问题，但这次我可以更精确，因为我现在有一个完成的工作程序，我可以用作实际示例。

您在调用 std::async 后立即调用get，这将导致程序等待结果可用。在等待之前，您需要启动两个异步任务：

auto future1 = async(launch::async, &ProcessEngine, 0, sampleFrames);
auto future2 = async(launch::async, &ProcessEngine, 1, sampleFrames);
STEREOOUT e0 = future1.get();
STEREOOUT e1 = future2.get();
相关文章：