std::async 仅同步工作

Question

我正在尝试向我的 A 星添加一个异步方法 Class。我希望能够异步计算路径，这样每个代理都能独立于其他代理找到自己的路径。

问题是，目前程序似乎正在等待线程完成。我如何异步执行每个调用？

函数

bool simplePath::navAgent::findPathAsync(int _startX, int _startY, int _endX, int _endY){
    auto t1 = std::async([&]{return this->findPath(_startX,_startY,_endX,_endY);});
    t1.get();
    return true;
}

致电

navComponent->findPathAsync(0,2,30,45);
    navComponent->findPathAsync(0,2,123,100);
    navComponent->findPathAsync(0,2,8,7);
    navComponent->findPathAsync(0,2,8,7);
    navComponent->findPathAsync(0,2,8,7);
    navComponent->findPathAsync(0,2,8,7);
    navComponent->findPathAsync(0,2,8,7);

我这里的错误是什么？

Answer 1

当您调用 t1.get() 时，您的代码正在等待计算结果。

当您启动任务时，您没有指定启动策略，因此您使用的是 std::launch::async | std::launch::deferred 的默认策略，它可能根本不会启动一个单独的线程，并且可以在您调用 t1.get().

您需要将 lambda 更改为按值捕获而不是按引用捕获，因为执行 lambda 时您引用的整数参数可能不再存在。

一个完整的例子是：

std::future<bool> simplePath::navAgent::findPathAsync(int _startX, int _startY, int _endX, int _endY){
    return std::async(std::launch::async, []{return this->findPath(_startX,_startY,_endX,_endY);});
}

std::vector< std::future_bool > results;
results.emplace_back(navComponent->findPathAsync(0,2,30,45));
results.emplace_back(navComponent->findPathAsync(0,2,123,100));
results.emplace_back(navComponent->findPathAsync(0,2,8,7));
results.emplace_back(navComponent->findPathAsync(0,2,8,7));
results.emplace_back(navComponent->findPathAsync(0,2,8,7));
results.emplace_back(navComponent->findPathAsync(0,2,8,7));
results.emplace_back(navComponent->findPathAsync(0,2,8,7));

bool result = true;
for ( auto& f : results )
{
    result &= f.get();
}

std::async 仅同步工作

std::async works only synchronously

c++

lambda

asynchronous

future