c++ - Boost::Future 延迟延续展开死锁

Question

我正在使用 Boost 的 promise 和 future 并在使用延续时遇到了边缘情况。我的代码使用一个返回 future 的延续，并在获取其值之前解包 then() 的结果。

#define BOOST_THREAD_VERSION 5

#include <iostream>
#include <boost/thread/future.hpp>

int main(int argc, char* argv[])
{
    boost::promise<int> promise;
    boost::future<int> future = promise.get_future();

    promise.set_value(42);

    int result = future.then(
        boost::launch::async,
        [](boost::future<int> result)
        {
            return boost::make_ready_future(result.get());
        }
    ).unwrap().get();

    std::cout << "Result is: " << result << std::endl;
    return 0;
}

在此示例中，我明确使用了 boost::launch::async 策略在新线程中启动延续，我得到了预期结果 42。

但是，一旦我用 boost::launch::deferred 替换该策略，程序似乎就会死锁。我做错了什么？

注意:只要我不 unwrap() 它的值，延迟延续就可以正常工作。该问题特别与未包装的延迟延续有关。

Answer 1

我认为 future continuation 与 unwrap 搭配使用没有意义。如果您使用 .then 创建一个 future ，您将获得一个有效的 future 。所以你可以调用 .get() 而不会阻塞。这就是为什么我不认为需要嵌套的 future 。但是，您编写它的方式不应该导致死锁，它可能是一个错误。

#define BOOST_THREAD_VERSION 5

#include <iostream>
#include <boost/thread/future.hpp>

int main(int argc, char* argv[])
{
    boost::promise<int> promise;
    boost::future<int> future = promise.get_future();

    promise.set_value(42);

    int result = future.then(
        boost::launch::deferred,
        [](boost::future<int> result)
        {
            return result.get(); // get is non-blocking, since it is a continuation
        }
    )/*.unwrap()*/.get();

    std::cout << "Result is: " << result << std::endl;
    return 0;
}

从 boost 1.64 开始，unwrap 仍然是一个实验性函数。如果您将此行为传达给 boost::thread 的开发人员，那就太好了。