为什么 boost::future<T>::then() 会产生一个新线程？

Question

将延续附加到boost::future 时，延续在新线程中执行：

std::cout << "main: " << boost::this_thread::get_id() << std::endl;

boost::promise<void> p;
boost::future<void> f = p.get_future();
p.set_value();

boost::future<void> f2 = f.then([] (boost::future<void>) {
    std::cout << "future: " << boost::this_thread::get_id() << std::endl;        
});

这个 sn-p 输出：

main: 0x7fff7a8d7310
future: 0x101781000

为什么.then() 允许这样做，更重要的是，有没有办法自定义这种行为？从promise/packaged_task/async 返回的futures 行为是否不同？

Answer 1

@ikh 回答中已经提到过。但为了更清楚，这里是对 OP 问题的直接答案。

boost::future continuation 应该在新线程还是在调用线程中执行是可定制的。

boost::launch 策略参数指定延续应该如何运行。见这里：Enumeration launch

enum class launch
{
    none = unspecified,
    async = unspecified,
    deferred = unspecified,
    executor = unspecified,
    inherit = unspecified,
    any = async | deferred
};

async(launch::deferred, ...) 或 ::then(launch::deferred, ...) 创建的未来已关联启动策略 launch::deferred。

所以，试试运行这个：

boost::future<void> f2 = f.then(
    boost::launch::deferred,
    [] (boost::future<void>&&) {
        std::cout << "future: " << boost::this_thread::get_id() << std::endl;        
    }
);

这应该在同一个线程中运行延续。
在 Windows 平台上使用 boost 1.61 + Visual Studio 2015 进行测试。

Answer 2

产生一个新线程是合理的。看看这段代码：

std::cout << "main: " << boost::this_thread::get_id() << std::endl;

boost::promise<void> p;
boost::future<void> f = p.get_future();
p.set_value();

boost::future<void> f2 = f.then([] (boost::future<void>) {
    SomeVeryVeryVeryLongLongLongLongTask();

    std::cout << "future: " << boost::this_thread::get_id() << std::endl;        
});

在不产生新线程的情况下，我们必须在f.then(... 处等待SomeVeryVeryVeryLongLongLongLongTask()。

---

如果您想查看某些证据？在reference，

• 如果父级是使用 promise（没有关联的启动策略）创建的，则延续的行为与使用策略参数 launch::async | 的第三个重载相同。 launch::deferred 和 func 的参数相同。

如您所知，如果我们使用launch::async | launch::deferred，我们不知道是生成了一个新线程还是只是延迟了它。但主要是产生了一个新线程，对吧？

PS。嗯？参考说“...promisepromise<> 打错了>o

PS2。请参阅@sehe 的回复。严格来说，他是对的。