调用std::Package_TASK::Get_Future()时可能出现争用情况
在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
更新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
已被移出,因为这是您要求执行的操作。
相关文章