为什么我的线程调用函数对象而不是将其返回值分配给packaged_task的未来对象

Why does my thread invoke a function object instead of assigning its return value to my packaged_task’s future object?

本文关键字：对象 packaged 分配 返回值 未来 task 调用 线程 我的 函数 为什么      更新时间：2023-10-16

我想学习如何使用packaged_task检索函数的返回值。

在下面的代码中，我创建了一个运行我的函数 DoTask 的线程。然后，我将该函数绑定到packaged_task并让它等待，同时将其绑定到packaged_task myTask。我提取了myTask的未来对象。现在，我在 DoTask （notify_one） 上取消阻止条件变量，让它运行完成。我对myTask的未来做了一个get（）来检索DoTask中返回布尔值的值。

但是，DoTask不是等待DoTask返回，而是输入执行"调用函数对象"的代码，并且get（）永远不会被执行。

是什么阻止了 DoTask 设置我期望的未来，而是调用函数对象？

#include "stdafx.h"
#include <future>
#include <memory>
#include <thread>
#include <condition_variable>
#include <mutex>
std::condition_variable notifyCondVar;
std::mutex mu;
bool DoTask() 
{
  {
    std::unique_lock< std::mutex > locker( mu );
    notifyCondVar.wait( locker );
  }
  return true;
}
int main()
{
  std::thread packageTaskThread( DoTask );
  std::packaged_task< bool() > myTask( std::bind( DoTask ) );
  std::future< bool > taskFuture = myTask.get_future();
  notifyCondVar.notify_one();
  bool okay = taskFuture.get();
  packageTaskThread.join();
  return 0;
}

你有一个线程运行DoTask，并指示一个packaged_task运行DoTask。您从未实际执行过任务，因此以下两件事是错误的：

  1. 线程永远不会终止;
  2. 这项任务的未来永远不会得到满足。

也许你的意思是从打包的任务中移动构造线程，而不是：

#include <future>
#include <memory>
#include <thread>
#include <condition_variable>
#include <mutex>
std::condition_variable notifyCondVar;
std::mutex mu;
bool DoTask() 
{
  std::unique_lock<std::mutex> locker(mu);
  notifyCondVar.wait(locker);
  return true;
}
int main()
{
  std::packaged_task<bool()> myTask([]() { return DoTask(); });
  std::future<bool> taskFuture = myTask.get_future();
  std::thread packageTaskThread(std::move(myTask));
  notifyCondVar.notify_one();
  bool okay = taskFuture.get();
  packageTaskThread.join();
}

您可以在本文档中查看std::packaged_task的使用示例。

（顺便说一句，您在DoTask中的额外范围块是完全多余的。

相关文章：