multithreading - std::promise左值引用与右值引用之间的区别

Question

我的理解是，如果我们调用从promise获取的future Future，它将等待直到调用set_value，如果从未调用该程序，它将永远等待，但是以某种方式，当我使用promise rvalue引用时，此行为不起作用(它抛出了破损的promise future 的错误)，尽管同样适用于左值引用(永远等待)。有什么理由因为我相信在右值引用的情况下也应该永远等待？

#include <iostream>
#include <future>
#include <thread>
#include <chrono>
void calculateValue(std::promise<int> &&p)
//void calculateValue(std::promise<int> &p) //uncomment this it will wait
{
  using namespace std::chrono_literals;

  std::cout<<"This is start of thread function "<<std::endl;
  //Do long operations
  std::this_thread::sleep_for(2s);
 // p.set_value(8);
  std::cout<<"This is end of thread function "<<std::endl;

}
int main() {

  std::promise<int> p;
  auto  fut = p.get_future();
  std::thread t(calculateValue,std::move(p));
  //uncomment this it will wait
  //std::thread t(calculateValue,std::ref(p);
  std::cout<<"main function ..."<<std::endl;
  std::cout<<"value is "<<fut.get()<<std::endl;
  t.join();
  return 0;

}

Answer 1

当使用这种形式的thread的构造函数时:

std::thread t(calculateValue, std::move(p));

然后在内部将 p从 std::promise移到一个临时对象中。此临时变量用作 calculateValue 的参数，独立于其参数类型的:

void calculateValue(std::promise<int> &&p) // option #1
void calculateValue(std::promise<int> p)   // option #2

在线程完成执行之前，临时(或第二种情况下的 p参数)被销毁，这会触发 std::future_error，因为共享状态尚未就绪(尚未调用 set_value)。

但是，如果您使用 std::reference_wrapper:

std::thread t(calculateValue, std::ref(p));

然后，原始的Promise不会被移走，它仍然存在，并且直到 main末尾才调用其析构函数。由于主线程将在 fut.get()上等待，因此这是永远不会达到的。

底线:问题根本与 calculateValue的参数形式无关。它关于您是否从 p移到临时字段的信息，该字段有效地定义了与将来(及其共享状态)有关的Promise的析构函数是否被销毁。