调用std::Package_TASK::Get_Future()时可能出现争用情况可能出现、情况、std、Package_TASK

2023-09-04 01:46:29 作者:怀念丶那个人

在document处可以看到,有一个演示片段:

std::packaged_task<int()> task([]{ return 7; }); // wrap the function
std::future<int> f1 = task.get_future();  // get a future
std::thread t(std::move(task)); // launch on a thread

我的问题是,如果我像这样重写代码片段,是否存在任何问题(竞态条件):

std::packaged_task<int()> task([]{ return 7; }); // wrap the function
std::thread t(std::move(task)); // firstly launch on a thread, and then gets a future
std::future<int> f1 = task.get_future();  // get a future
里程碑式 Dubbo 2.7.5 版本发布,性能提升30 ,支持 HTTP 2 TLS Protobuf等特性

更新1:我理解Nicol Bolas的回答,如果我像这样重写代码片段,是否会有任何潜在的问题(竞态条件):

std::packaged_task<int()> task([]{ return 7;});
thread_callablefunc_queue.push_back(task);  //task may be popped and run by another thread at once, queue is protected by mutex.
std::future<int> f1 = task.get_future();  // get a future

让我担心的是,当当前线程正在调用task.get_future()时,task可能会被同时被调用。

推荐答案

是的,有问题。您移动了task。您的线程不再拥有它;此时的task变量处于有效但未指定的状态。你不能问它的未来,因为它不代表有问题的任务...因为你移动了它。

这不是争用条件;它在功能上与此没有区别:

std::packaged_task<int()> task([]{ return 7; });
auto t(std::move(task));
std::future<int> f1 = task.get_future();

task已被移出,因为这是您要求执行的操作。